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

Question

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

Answer 1

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

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