关于 kafka 监听轮询

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

现在注册

已注册用户请登录

这是一个创建于 2656 天前的主题，其中的信息可能已经有所发展或是发生改变。

spring-boot 和 kafka 整合的配置文件中有

spring.kafka.listener.poll-timeout=10000
spring.kafka.consumer.max-poll-records=5

这两个参数如何理解？ 10 秒钟轮询一次？每次最多只能获取 5 个记录？

4 条回复 • 2017-08-18 20:27:56 +08:00

ztmark

2017-08-17 19:56:48 +08:00

timeout 是超时

guyeuro

2017-08-18 10:03:43 +08:00

@ztmark 超时什么？怎么理解？

ztmark

2017-08-18 19:46:33 +08:00

@guyeuro 就是在 consumer 阻塞在获取消息的超时时间，应该是跟 kafka 的 request.timeout.ms 对应吧

guyeuro

2017-08-18 20:27:56 +08:00

@ztmark 意思是 10 秒钟轮询一次？