3
我在考虑使用0.9 API版本构建Kafka使用者。请你能解释消费者重新平衡的含义吗?这里提到的消费者和协调员之间有什么区别?也请你能解释消费者脑裂问题吗?Kafka Consumer - Java(0.9 API)
以下是设计草案,它使用经纪人方的高可用消费者协调员来处理消费者重新平衡。通过 将重新平衡逻辑从消费者迁移到协调者,我们 可以解决消费者裂脑问题并帮助消费者客户端更细。
我在考虑使用0.9 API版本构建Kafka使用者。请你能解释消费者重新平衡的含义吗?这里提到的消费者和协调员之间有什么区别?也请你能解释消费者脑裂问题吗?Kafka Consumer - Java(0.9 API)
以下是设计草案,它使用经纪人方的高可用消费者协调员来处理消费者重新平衡。通过 将重新平衡逻辑从消费者迁移到协调者,我们 可以解决消费者裂脑问题并帮助消费者客户端更细。
嗨鹦鹉螺,消费者可以在使用kafka api 0.8.2版本时重新平衡,或者它只能在0.9版本中使用 –
是否共同构建了kafka并知道所有的ips消费应用程序 –
对不起,我对老消费者不是很熟悉。你可以在这里问问email:[email protected] – Nautilus