V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
V2EX 提问指南
guyeuro
V2EX  ›  问与答

关于 kafka 监听轮询

  •  
  •   guyeuro · 2017-08-17 18:36:37 +08:00 · 2916 次点击
    这是一个创建于 2653 天前的主题,其中的信息可能已经有所发展或是发生改变。

    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
        1
    ztmark  
       2017-08-17 19:56:48 +08:00
    timeout 是超时
    guyeuro
        2
    guyeuro  
    OP
       2017-08-18 10:03:43 +08:00
    @ztmark 超时什么?怎么理解?
    ztmark
        3
    ztmark  
       2017-08-18 19:46:33 +08:00
    @guyeuro 就是在 consumer 阻塞在获取消息的超时时间,应该是跟 kafka 的 request.timeout.ms 对应吧
    guyeuro
        4
    guyeuro  
    OP
       2017-08-18 20:27:56 +08:00
    @ztmark 意思是 10 秒钟轮询一次?
    关于   ·   帮助文档   ·   博客   ·   API   ·   FAQ   ·   实用小工具   ·   5265 人在线   最高记录 6679   ·     Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 · 22ms · UTC 07:25 · PVG 15:25 · LAX 23:25 · JFK 02:25
    Developed with CodeLauncher
    ♥ Do have faith in what you're doing.