spring-boot 和 kafka 整合的配置文件中有
spring.kafka.listener.poll-timeout=10000
spring.kafka.consumer.max-poll-records=5
这两个参数如何理解? 10 秒钟轮询一次? 每次最多只能获取 5 个记录?
1
ztmark Aug 17, 2017
timeout 是超时
|
3
ztmark Aug 18, 2017
@guyeuro 就是在 consumer 阻塞在获取消息的超时时间,应该是跟 kafka 的 request.timeout.ms 对应吧
|