动物园管理员会返回卡夫卡代理 dns 吗?(具有领导者分区)



我是Kafka的新手,我想问一个问题。

如果有 3 个 Kafka 代理(kafka1、kafka2、kafka3((它们在同一个 Kafka 集群中( 和主题=测试(复制=2( Kafka1 有 leader 分区,kafka2 有 follower 分区。

如果生产者将数据发送到 kafka3,那么存储在 kafka1 和 Kafka2 中的数据是如何存储的?

我听说,如果生产者将数据发送到 kafka3,那么动物园管理员会找到具有领导者分区的代理并返回代理的 dns 或 IP 地址。 然后,生产者将重新发送到代理元数据。

对吗?或者如果错了,请告诉我它是如何工作的。

多谢!

每个 kafka 主题分区都有自己的领导者。所以如果你有 2 个分区,kafka 会为每个分区分配领导者。它们最终可能是相同的 kafka 节点,也可能是不同的。

当生产者连接到 kafka 集群时,它会了解分区领导者。所有写入都必须经过相应的分区领导者,该索引负责跟踪同步副本。

所有使用者只与相应的分区领导者通信以获取数据。

如果分区领导者关闭,其中一个副本将成为领导者,并且所有生产者和使用者都会收到有关此更改的通知

最新更新