网上说提高heartbeat.interval.ms这个参数,可以避免rebalance,请问为什么,尽量从原理代码角度分析?
简单一点,就是心跳间隔,客户端定时发送心跳给kafka集群,告诉他,我还活着。当超过了这个时间,kafka集群还未收到心跳。则认为这个客户端已经不在了,发起重新平衡。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
简单一点,就是心跳间隔,客户端定时发送心跳给kafka集群,告诉他,我还活着。当超过了这个时间,kafka集群还未收到心跳。则认为这个客户端已经不在了,发起重新平衡。
你的答案