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

一如乞人不需要形象 发表于: 2020-12-25   最后更新时间: 2020-12-25 16:06:03   1,098 游览

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

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

谢谢~~

发表于 2020-12-25

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

我找到了这个参数,应该符合要求:
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.

你的答案

查看kafka相关的其他问题或提一个您自己的问题