apache-kafka - 将 kafka-console-producer.sh 运行到另一台服务器

Question

我已经在我的 centos 服务器上安装了 Apache Kafka。我只是想向另一台服务器上的主题写一条消息。所以安装后，我没有启动zookeeper或Kafka服务器，而是简单地输入命令：

echo testing | ./kafka-console-producer.sh --broker-list xxx.yyy.com:2181 --topic topicx

我可以从我的服务器 ping xxx.yyy.com。当我运行这个时，我得到这个错误：

错误 向主题 cds_organization 发送消息时出错，键：null，值：7 个字节，错误：
(org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: 主题 topicx not 60000 毫秒后出现在元数据中。

那么在这种情况下，我还需要启动 zookeeper 和/或 kafka 服务器吗？

标签： apache-kafkakafka-producer-api

Answer 1

“ ./kafka-console-producer.sh --broker-list xxx.yyy.com:2181 --topic topicx ”，你的逗号，错过了这部分，是你的broker监听端口2181，通常是9092。
更改逗号到“ ./kafka-console-producer.sh --broker-list xxx.yyy.com:9092 --topic topicx ”并重试