apache-kafka - 如何在 kafka 消费组的情况下引入再平衡延迟？

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

标签： apache-kafkaapache-kafka-streams

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

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