Kafka 节点如何相互通信?
How Kafka Nodes communicate with each other?
我找不到有关集群内 Kafka 节点相互通信的任何详细信息。我的意思是在复制过程中,生产者将与其中一个节点联系。可以说它是领导者。现在对于复制,该数据也应该根据配置复制到其他节点。那么这是怎么发生的呢?这些通信是通过 zookeeper 集群发生的吗?或者,Leader 直接和 Follower 对话进行复制?如果他们直接通信,他们是在哪个端口上进行通信的?
生产者将消息发送到 Kafka 领导者,其他 Kafka 节点充当该领导者的客户端以进行复制,就像任何外部 Kafka 客户端一样。跟随者使用与领导者通信的相同端口为普通客户端公开,默认为 9092。
我找不到有关集群内 Kafka 节点相互通信的任何详细信息。我的意思是在复制过程中,生产者将与其中一个节点联系。可以说它是领导者。现在对于复制,该数据也应该根据配置复制到其他节点。那么这是怎么发生的呢?这些通信是通过 zookeeper 集群发生的吗?或者,Leader 直接和 Follower 对话进行复制?如果他们直接通信,他们是在哪个端口上进行通信的?
生产者将消息发送到 Kafka 领导者,其他 Kafka 节点充当该领导者的客户端以进行复制,就像任何外部 Kafka 客户端一样。跟随者使用与领导者通信的相同端口为普通客户端公开,默认为 9092。