我正在尝试设置apachekafka，以便在同一网络上运行centos的两个虚拟机之间进行通信。我最初在一台机器上建立了一个Kafka生产商和消费者，一切都很顺利。然后我在另一台机器上设置了kafka，在尝试让它们连接的过程中，我得到了错误“bootstrap server is not a recognized option”（我运行的是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 计算机正在运行服务器本身。
3条答案
按热度按时间jrcvhitl1#
根据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-serverss2ws0br2#
./kafka-console-consumer.sh--zookeeperlocalhost:2181 --topic 弗雷德
简单地发出这个命令就行了。不过，在即将发布的主要版本中，使用选项bootstrap server将是强制性的。
当我使用上面的命令时，它给出了一个警告：“将consoleconsumer与旧使用者一起使用是不推荐的，并且将在将来的主要版本中删除。请考虑通过传递[bootstrap server]而不是[zookeeper]来使用新使用者。”
56lgkhnf3#
下面的命令应该有效。