你好,请教个问题,在用kafka时,配置两个partition,两个consumer,当关闭其中一个consumer,引起kafka的rebalance,导致可用的consumer接受消息延时8秒。因为网络环境,会时常引起网络波动,导致consumer不可用,然后出现延迟,请这个问题怎么解决
你的kafka的版本是?
rebalance是kafka的内部机制,你可以看下kafka日志,看看rebalance有没有异常。
你的带宽可能被平衡给占用了。
可以考虑限流:https://www.orchome.com/510
kafka-clients 0.9.0.1已经修复了这个bug
你的答案