kafka rebalance导致consumer接受消息延迟

老船长 发表于: 2016-07-29   最后更新时间: 2016-07-29 13:27:22   8,065 游览

你好,请教个问题,在用kafka时,配置两个partition,两个consumer,当关闭其中一个consumer,引起kafka的rebalance,导致可用的consumer接受消息延时8秒。因为网络环境,会时常引起网络波动,导致consumer不可用,然后出现延迟,请这个问题怎么解决

发表于 2016-07-29
添加评论

你的kafka的版本是?

rebalance是kafka的内部机制,你可以看下kafka日志,看看rebalance有没有异常。

半兽人 -> 半兽人 3年前

你的带宽可能被平衡给占用了。
可以考虑限流:https://www.orchome.com/510

kafka-clients 0.9.0.1已经修复了这个bug

你的答案

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