本文介绍了在卡夫卡消费群体的情况下,如何引入重新平衡的延迟?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
我想给我的使用者一些时间来重新启动,以便不会发生不必要的重新平衡.我怎样才能做到这一点?在关机的情况下,我希望复制出现,如果一段时间后不备份使用者,则应该进行重新平衡,否则就不会发生.
I want to give some time to my consumer to restart so that unnecessary rebalance doesnt happen. How can I do that?In case of shutdown, I want replication to come in picture and after some time if consumer is not back up, rebalance should occur else not.
推荐答案
您可以进行调整,称为 group.initial.rebalance.delay.ms
的代理级配置.
There's broker level config called group.initial.rebalance.delay.ms
you can tweak.
https://kafka.apache.org/documentation/
这篇关于在卡夫卡消费群体的情况下,如何引入重新平衡的延迟?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持!