我正在考虑使用0.9API版本构建一个Kafka消费者。请你解释一下什么是消费者再平衡?这里提到的消费者和协调者之间有什么区别?另外,请你解释一下消费者的大脑分裂问题?
下面是一个设计草案,它在代理端使用一个高可用的消费者协调器来处理消费者再平衡。通过将再平衡逻辑从使用者迁移到协调器,我们可以解决消费者分裂的大脑问题,并帮助减轻消费者客户端的负担。
发布于 2016-02-23 18:51:25
消费者再平衡意味着消费者组正在重新平衡该消费者组的消费者之间的分区,当一个新的消费者进入或离开该组时就会发生这种情况。
每个消费群体都有一个基本协调小组的协调者。
如果您想了解更多关于新消费者的信息,可以阅读这。
而脑分裂是分布式系统中的一个常见问题,当存在网络分区时,系统的不同部分无法相互通信,无法实现这一点。你可以查一下这里
https://stackoverflow.com/questions/35584650
复制相似问题