Kafka 消费者 - Java (0.9 API)

Kafka Consumer - Java (0.9 API)

我正在考虑使用 0.9 API 版本构建 Kafka 消费者。请您解释一下消费者再平衡是什么意思?这里提到的消费者和协调者有什么区别?还请你解释一下消费者裂脑问题吗?

The following is a draft design that uses a high-available consumer coordinator at the broker side to handle consumer rebalance. By migrating the rebalance logic from the consumer to the coordinator we can resolve the consumer split brain problem and help thinner the consumer client.

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

每个消费者组都有一个协调器,基本上协调组。

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

脑裂是分布式系统的一个常见问题,当存在网络分区并且系统的不同部分无法相互通信并且没有意识到这一点时就会发生。你可以查一下 here