apache-kafka - Apache Kafka 中的分区领导者是什么？

Question

kafka 领导者是自己分区还是经纪人？
我最初的理解是，它们是充当读/写代理的分区，然后将它们的值(value)交给 ISR。

但是最近我听到他们提到他们好像发生在“经纪人”级别，因此我很困惑。

我知道还有其他帖子旨在回答这个问题，但那里的答案没有帮助。

Answer 1

这里的一些答案并不完全正确，所以我想说得更清楚。

每个分区恰好有一个分区领导者来处理该分区的所有读/写请求。
如果复制因子大于 1，则附加分区复制将充当分区跟随者。
Kafka 保证每个分区副本都驻留在不同的代理上 (无论是leader还是follower)，所以最大复制因子就是broker数。

每个分区跟随者都从分区领导者那里读取消息(就像一种消费者)并且不为该分区的任何消费者提供服务 (只有分区领导者提供读/写)。
如果分区跟随器不断从分区领导者读取数据而不会滞后并且不会失去与 ZooKeeper 的连接(最大滞后默认为 10 秒，ZooKeeper 超时为 6，它们都可配置)，则它被认为是同步的。
如果分区跟随器滞后，则认为不同步。
当分区领导者因任何原因关闭时(实际上它所在的代理关闭)，它的同步分区追随者之一将成为新的领导者。

replication section in Kafka Documentation详细解释了这一点。
Confluent 也写了一篇不错的blog关于这个话题。