我找不到关于集群中kafka节点相互通信的任何细节。我的意思是在复制过程中，producer将与其中一个节点联系。我们可以说是领导者。现在对于复制，也应该根据配置将数据复制到其他节点。那么这是怎么发生的呢？这些通信是通过zookeeper集群进行的吗？或者，领导者直接与跟随者对话以进行复制？如果他们直接通信，他们是在哪个端口进行的？
hlswsv351#
生产者将消息发送给kafka leader，其他kafka节点作为客户端发送给该leader进行复制，就像任何外部kafka客户端一样。follower使用与普通客户机相同的端口（默认为9092）与leader通信。
1条答案
按热度按时间hlswsv351#
生产者将消息发送给kafka leader，其他kafka节点作为客户端发送给该leader进行复制，就像任何外部kafka客户端一样。follower使用与普通客户机相同的端口（默认为9092）与leader通信。