将消息发布到集群中的一个Kafka代理的影响

问题描述

我有带有三个代理和Zookeeper实例的Kafka集群。每个分区的复制因子保持为2。

我想通过提供一个代理地址来了解将消息发布到集群中的单个节点的影响。如果消息适合其他经纪人持有的分区，该经纪人是否会向其他经纪人发送消息？

有人可以解释内部同步的工作原理还是指向资源。

解决方法

提供一个经纪人地址

即使您提供一个地址，引导协议也会将所有代理返回给客户端。

分区器逻辑确定将数据发送到哪个代理中的哪个分区-您以分区为目标，而不是客户端中的代理。