如何在卡夫卡消费群体的情况下引入再平衡延迟



我想给我的使用者一些时间来重新启动,这样就不会发生不必要的重新平衡。我该怎么做?在关闭的情况下,我希望复制出现在图片中,一段时间后,如果消费者没有备份,应该进行重新平衡,否则不会。

有一个名为group.initial.rebalance.delay.ms的代理级配置,您可以进行调整。

组协调员等待更多消费者的时间 以在执行第一次重新平衡之前加入新组。更长的 延迟意味着重新平衡可能更少,但会增加时间,直到 处理开始。

https://kafka.apache.org/documentation/

相关内容

  • 没有找到相关文章

最新更新