Kafka 如何选择跟随节点进行复制？

Question

Kafka 在多台机器上复制主题的分区以实现容错。 每个分区都有一个领导者和一个或多个追随者。

我想知道 Kafka 如何在可能的候选者中选择将成为每个主题/分区的追随者的机器？

例如，假设有 1 个主题具有 3 个分区 {A,B,C}，复制因子为 3。Kafka 在 6 台机器上运行 {1,2,...,6}。

一个可能的分配是：

1 2 3 4 5 6
A B C
C A B
B C A

但以下情况也是可能的：

1 2 3 4 5 6
A B C
  A B C
    A B C

当然，有很多可能的任务。

谁能告诉我卡夫卡是如何做到这一点的？

谢谢

Answer 1

您可以查看 github 上的 Kafka 源代码，了解它在默认情况下如何进行副本分配 - https://github.com/apache/kafka/blob/0.10.0/core/src/main/scala/kafka/admin/AdminUtils.scala#L47-L106