hadoop - Kafka console producer 在 Hortonworks HDP 2.3 Sandbox 中出错

Question

我找遍了，没找到错误。我检查了This Stackoverflow Issue 但这不是我的问题

1. 我已经启动了一个 zookeeper 服务器

   

启动服务器的命令是

 bin/zookeeper-server-start.sh config/zookeeper.properties

1. 然后我使用 Putty 通过 SSH 连接到 VM 并使用启动 kafka 服务器

   $ bin/kafka-server-start.sh config/server.properties

2. 然后我创建了 Kafka 主题，当我列出主题时，它就会出现。

3. 然后我打开另一个 putty 并启动 kafka-console-producer.sh 并输入任何消息(甚至输入)并得到这个长的重复异常。

zookeeper.properties、server.properties、kafka-producer.properties的配置文件如下(分别)

我运行的Kafka版本是8.2.2。我在 kafka/libs 文件夹中看到的东西。P.S. 我在消费者中没有收到消息。

任何人都可以解决这个问题吗？我遵循的教程是 [This][9]

8 http://%60http://www.bogotobogo.com/Hadoop/BigData_hadoop_Zookeeper_Kafka_single_node_single_broker_cluster.php%60

Answer 1

在 hortonworks 沙盒上查看服务器配置:

$ less /etc/kafka/conf/server.properties

在我的例子中它说

...
listeners=PLAINTEXT://sandbox.hortonworks.com:6667
...

这意味着您必须使用以下命令才能成功连接到控制台生产者

$ cd /usr/hdp/current/kafka-broker
$ bin/kafka-console-producer.sh --topic test --broker-list sandbox.hortonworks.com:6667

如果您使用 --broker-list 127.0.0.1:6667 或 --broker-list localhost:6667 ，它将不起作用。另见 http://docs.hortonworks.com/HDPDocuments/HDP2/HDP-2.3.0/bk_installing_manually_book/content/configure_kafka.html

消费消息使用

$ bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning