我想给我的消费者一些时间来重新启动,这样就不会发生不必要的重新平衡。我怎样才能做到这一点? 在关闭的情况下,我希望复制能够出现,并且一段时间后如果消费者没有备份,则应该发生重新平衡,否则不会。
有名为
group.initial.rebalance.delay.ms
组协调员等待更多消费者的时间 在执行第一次重新平衡之前加入新组。更长的 延迟意味着可能会减少重新平衡,但会增加直到 处理开始。
https://kafka.apache.org/documentation/
看起来这个问题已通过客户端配置同时解决:
https://github.com/tulios/kafkajs/issues/1237