kafka Coordinator 等待消费者加入的time-out参数是哪个？以及time-out策略是什么？

一如乞人不需要形象 发表于: 2020-12-25   最后更新时间: 2020-12-25  

coordinator 在发现有新的consumer加入时，会开启rebalance, 此时会有个配置，表示等待consumer加入直到多久，忘记这个参数是什么了？

还有就是这个参数的策略是什么？是第一个consumer加入后开始计时，时间t后停止，开始sync，还是每次发现新的consumer加入后，重新开始计时？

谢谢～～



您需要解锁本帖隐藏内容请： 点击这里
本帖隐藏的内容




上一条: 付费下载了使用工具里面的Kafka客户端代码, 我该怎么集成到项目呢?
下一条: kafka stream分布式


  • 半兽人 1月前

    没有你的这个参数...
    你可以到这里查看，搜索关键字平衡或"新的"：
    https://www.orchome.com/535

    • 一如乞人不需要形象 半兽人 . 1月前

      我找到了这个参数，应该符合要求：
      A new config, group.initial.rebalance.delay.ms, was introduced. This config specifies the time, in milliseconds, that the GroupCoordinator will delay the initial consumer rebalance. The rebalance will be further delayed by the value of group.initial.rebalance.delay.ms as new members join the group, up to a maximum of max.poll.interval.ms. The default value for this is 3 seconds. During development and testing it might be desirable to set this to 0 in order to not delay test execution time.