Kafka消费者配置问题

淡忘莫相 发表于: 2019-09-09   最后更新时间: 2019-09-09  

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



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: Kafka topic中有数据,但是消费者poll不到数据,重启下就可以poll到数据,想问下是什么原因
下一条: nigix转发kafka 连不上

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

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