Sam*_*ash 3 hadoop apache-kafka hortonworks-data-platform
我已经搜索了所有内容,但找不到错误。我已经检查了这个 Stackoverflow 问题,但这不是我的问题
启动服务器的命令是
bin/zookeeper-server-start.sh config/zookeeper.properties
Run Code Online (Sandbox Code Playgroud)
然后我使用 Putty SSH 到 VM 并使用启动 kafka 服务器
$ bin/kafka-server-start.sh config/server.properties

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

我运行的 Kafka 版本是 8.2.2。我在 kafka/libs 文件夹中看到的东西。 PS我在消费者中没有收到任何消息。
任何身体都可以找出问题吗?我遵循的教程是[这个][9]
8 http://%60http://www.bogotobogo.com/Hadoop/BigData_hadoop_Zookeeper_Kafka_single_node_single_broker_cluster.php%60
在 hortonworks 沙箱上查看服务器配置:
$ less /etc/kafka/conf/server.properties
Run Code Online (Sandbox Code Playgroud)
就我而言,它说
...
listeners=PLAINTEXT://sandbox.hortonworks.com:6667
...
Run Code Online (Sandbox Code Playgroud)
这意味着您必须使用以下命令才能成功连接到控制台生产者
$ cd /usr/hdp/current/kafka-broker
$ bin/kafka-console-producer.sh --topic test --broker-list sandbox.hortonworks.com:6667
Run Code Online (Sandbox Code Playgroud)
如果您使用--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
Run Code Online (Sandbox Code Playgroud)