Apache kafka 代理消费消息给其他人

Question

我有一个本地 Apache Kafka 设置，端口 9092 和 9093 上共有 2 个代理（id - 0 和 1）。 我创建了一个主题并使用此命令发布了消息：

bin/kafka-console.-producer.sh --broker-list localhost:9092 --topic test

然后我使用命令在其他终端上消费了消息：

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

到目前为止一切都很好。 但是当我输入命令时 -

bin/kafka-console.-producer.sh --broker-list localhost:9093 --topic test

并在我输入此命令的第二个终端中写入显示的一些消息 -

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test

为什么 9093 端口的消息会发布到 9092？

Answer 1

您的集群包含两个代理。用于初始连接的主机并不重要。使用 kafka 客户端，您无需指定从哪个代理消费或向哪个生产消息。这些主机名仅用于发现整个 kafka 代理列表（集群）

根据文档： https://kafka.apache.org/documentation/#producerconfigs https://kafka.apache.org/documentation/#consumerconfigs

bootstrap.servers::

用于建立与 Kafka 集群的初始连接的主机/端口对列表。客户端将使用所有服务器，无论此处指定哪些服务器进行引导 - 此列表仅影响用于发现完整服务器集的初始主机。