问Kafka内部经纪人沟通

EN

生产者/消费者向其中一个代理请求元数据(因为每个代理都缓存元数据)，这就是他们如何知道谁是分区的领导者。

关于“这是真的”一节：

1. 经纪人知道谁是给定分区的领导者，这要感谢zk和他们中的一个。更确切地说，他们中的一人决定谁将成为领导者。那个经纪人叫主计长。第一个连接到动物园管理员的经纪人变成了一个控制器，他的角色是决定哪个经纪人将是领导者，哪个经纪人将是复制者，并将其告知他们。控制器本身不排除在此过程中。它和其他的经纪人一样，肩负着挑选领导者和复制品的特殊责任。
2. zk确实能检测到经纪人何时去世/离开，但不会重新选举领导人。这是控制器的责任。当其中一个代理离开集群时，控制器从zk获取信息并开始重新分配。

关于你的问题-经纪人确实彼此交流(副本正在读取来自领导者的消息，控制器正在通知其他经纪人关于变化的信息)，但是它们之间不交换元数据--它们将元数据写入动物园管理员。

代理是在Kafka集群中运行的卡夫卡服务器

一个Kafka集群由多个Kafka Broker组成。每个Kafka broker都有一个唯一的ID (编号)。Kafka Brokers包含主题日志分区。连接到一个代理引导一个客户端到整个Kafka集群

每个代理包含许多分区，每个分区都可以是主题的领导者或副本。所有对主题的写入和读取都要经过领导和领导者协调，用新的数据更新副本。如果一个领导者失败了，一个复制品取代了新的领导者。