Kafka消费者配置问题

淡忘莫相 发表于: 2019-09-09   最后更新时间: 2019-09-09 14:54:39   1,505 游览

Kafka消费者控制拉取超时的有个地方,一个是consumer.poll(timeout) ,另一个是consumer的参数配置:fetch.max.wait.ms,想问下,这两个的区别在哪,如果他们设置的值不同,又有什么影响?

发表于 2019-09-09

消费者拉取消息,都是批量拉取的,如果该批次的消息不满足fetch.min.bytes,则最大等待多久之后(fetch.max.wait.ms),不管满不满足,都返回给消费者。

consumer.poll(timeout)是如果没消息,多长时间询问一次。

淡忘莫相 -> 半兽人 4年前

好的,谢谢!

你的答案

查看kafka相关的其他问题或提一个您自己的问题