Kafka消费者控制拉取超时的有个地方,一个是consumer.poll(timeout) ,另一个是consumer的参数配置:fetch.max.wait.ms,想问下,这两个的区别在哪,如果他们设置的值不同,又有什么影响?
消费者拉取消息,都是批量拉取的,如果该批次的消息不满足
fetch.min.bytes
,则最大等待多久之后(fetch.max.wait.ms),不管满不满足,都返回给消费者。consumer.poll(timeout)
是如果没消息,多长时间询问一次。好的,谢谢!
你的答案