【发布时间】:2021-01-09 16:42:13
【问题描述】:
我有 Kafka 集群,其中包含三个代理和 zookeeper 实例。保持每个分区的复制因子为 2。
我想通过提供一个代理地址来了解将消息发布到集群中的单个节点的影响。如果消息适合其他代理持有的分区,该代理会向其他代理发送消息吗?
有人可以解释内部同步的工作原理还是指向资源。
【问题讨论】:
标签: apache-kafka apache-zookeeper
我有 Kafka 集群,其中包含三个代理和 zookeeper 实例。保持每个分区的复制因子为 2。
我想通过提供一个代理地址来了解将消息发布到集群中的单个节点的影响。如果消息适合其他代理持有的分区,该代理会向其他代理发送消息吗?
有人可以解释内部同步的工作原理还是指向资源。
【问题讨论】:
标签: apache-kafka apache-zookeeper
提供一个经纪人地址
即使您提供一个地址,引导协议也会将所有代理返回给客户端。
分区器逻辑确定将数据发送到哪个代理中的哪个分区 - 您的目标是分区,而不是客户端中的代理。
【讨论】: