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