kafka的heartbeat.interval.ms作用是什么,能够解决Commit cannot be completed due to group rebalance

╰(‵□′)╯ 发表于: 2017-09-29   最后更新时间: 2017-09-29 17:37:38   6,842 游览

网上说提高heartbeat.interval.ms这个参数,可以避免rebalance,请问为什么,尽量从原理代码角度分析?

发表于 2017-09-29
添加评论

简单一点,就是心跳间隔,客户端定时发送心跳给kafka集群,告诉他,我还活着。当超过了这个时间,kafka集群还未收到心跳。则认为这个客户端已经不在了,发起重新平衡。

你的答案

查看kafka相关的其他问题或提一个您自己的问题