2016-02-23 106 views
3

我在考虑使用0.9 API版本构建Kafka使用者。请你能解释消费者重新平衡的含义吗?这里提到的消费者和协调员之间有什么区别?也请你能解释消费者脑裂问题吗?Kafka Consumer - Java(0.9 API)

以下是设计草案,它使用经纪人方的高可用消费者协调员来处理消费者重新平衡。通过 将重新平衡逻辑从消费者迁移到协调者,我们 可以解决消费者裂脑问题并帮助消费者客户端更细。

回答

2

消费者重新平衡意味着消费群体正在重新平衡消费群体消费者之间的分区,这种情况发生在新消费者进入或离开该群体时。

每个消费者群体都有一个协调员,基本协调该群组。

如果您想了解更多关于新消费者的信息,您可以阅读this

分裂脑是分布式系统的一个常见问题,当网络分区发生时,系统的不同部分不能相互通信,也不会意识到这一点。你可以查看它here

+0

嗨鹦鹉螺,消费者可以在使用kafka api 0.8.2版本时重新平衡,或者它只能在0.9版本中使用 –

+0

是否共同构建了kafka并知道所有的ips消费应用程序 –

+0

对不起,我对老消费者不是很熟悉。你可以在这里问问email:[email protected] – Nautilus

相关问题