如何在kafka消费者组的情况下引入延迟重新平衡?

问题描述 投票:0回答:2

我想给我的消费者一些时间来重新启动,这样就不会发生不必要的重新平衡。我怎样才能做到这一点? 在关闭的情况下,我希望复制能够出现,并且一段时间后如果消费者没有备份,则应该发生重新平衡,否则不会。

apache-kafka apache-kafka-streams
2个回答
4
投票

有名为

group.initial.rebalance.delay.ms
的代理级别配置,您可以调整。

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

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


0
投票

看起来这个问题已通过客户端配置同时解决:

https://github.com/tulios/kafkajs/issues/1237

© www.soinside.com 2019 - 2024. All rights reserved.