Apache Kafka：bootstrap-server 不是公认的选项

Question

我正在尝试设置 Apache Kafka，以便在同一网络上运行 CentOS 的两个虚拟机之间进行通信。我最初在一台机器上设置了 Kafka 生产者和消费者，一切运行顺利。然后我在另一台机器上设置了 Kafka，在尝试让它们连接的过程中，我收到错误“bootstrap-server 不是一个可识别的选项”（我正在运行最新版本的 Kafka，2.2）。

这是我用来尝试生产者连接的方法：

bin/kafka-console-producer.sh --bootstrap-server 10.0.0.11:9092 --topic test

而在消费者方面：

bin/kafka-console-producer.sh --bootstrap-server 10.0.0.11:9092 --topic test

该10.0.0.11机器正在运行服务器本身。

Answer 1

根据 Apache Kafka 文档，可以在这里找到：https : //kafka.apache.org/documentation/#quickstart_send，您应该使用--broker-list属性来传递代理地址。

命令将是： ./bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

编辑

从 Apache Kafka 2.5 开始支持这两个选项，--broker-list并且--bootstrap-server. 建议之一是--bootstrap-server

Answer 2

以下命令应该可以工作。

./bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test