我把它找遍了，找不到错误。我已经检查了这个堆栈溢出问题，但这不是我的问题
我已经启动了zookeeper服务器
启动服务器的命令无效
bin/zookeeper-server-start.sh config/zookeeper.properties然后我使用putty ssh到vm中，并使用
$bin/kafka-server-start.sh配置/server.properties
然后我创建了Kafka主题，当我列出主题时，它就出现了。
然后我打开了另一个putty，启动kafka-console-producer.sh并输入任何消息（甚至回车），得到这个长时间重复的异常。
zookeeper.properties、server.properties和kafka-producer.properties的配置文件分别如下所示
我正在运行的Kafka版本是8.2.2。我在kafka/libs文件夹中看到的东西。p、 我在消费者网站上没有收到任何消息。
有人能解决这个问题吗？我遵循的教程是[this][9]
8http://%60http://www.bogotobogo.com/hadoop/bigdata_hadoop_zookeeper_kafka_single_node_single_broker_cluster.php%60
3条答案
按热度按时间gpfsuwkq1#
在Kafka内部，生产者和消费者（客户机）以及经纪人（服务器）之间都有一个对话。在这些对话中，客户机通常会向服务器请求管理特定分区的服务器代理的地址。答案总是一个完全限定的主机名。如果引用的代理的地址不是该代理的完全限定主机名，那么在kafka实现遇到麻烦的情况下，就不必详细说明了。
另一个很容易犯的错误，特别是在沙盒中，是用一个没有定义到dns的地址引用代理。这就是为什么集群上的每个节点都必须能够通过完全限定的主机名寻址集群中的每个其他节点。这也是为什么从同一台机器上运行的另一个虚拟映像访问沙盒时，必须将sandbox.hortonworks.com添加到映像的hosts文件中。
azpvetkf2#
正如您在问题中提到的，您使用的是hdp2.3，在运行consoleproducer时也是如此
你需要提供sandbox.hortonworks。com:6667 in 经纪人名单。
请在运行console consumer时使用相同的方法。
如果你还面临任何问题，请告诉我。
0wi1tuuw3#
在hortonworks沙盒上，查看服务器配置：
在我的情况下它说
这意味着您必须使用以下命令才能成功地连接到控制台生产者
如果你用的话，那就不行了
--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使用