相关疑难解决方法(0)

我能够在一台Linux机器上获得一个简单的单节点Kafka(kafka_2.11-0.8.2.1)本地工作,但是当我尝试远程运行生产者时,我遇到了一些令人困惑的错误.

我正在关注http://kafka.apache.org/documentation.html#quickstart上的快速入门指南.我停止了kafka进程并删除了/ tmp中的所有zookeeper和karma文件.我在本地10.0.0.0/24网络NAT-ed上有一个外部IP地址,所以我修改server.properties告诉zookeeper如何广播我的外部地址,按照https://medium.com/@thedude_rog/running-kafka- in-a-hybrid-cloud-environment-17a8f3cfc284:

advertised.host.name=MY.EXTERNAL.IP

然后我运行这个:

$ bin/zookeeper-server-start.sh config/zookeeper.properties
--> ...
$ export KAFKA_HEAP_OPTS="-Xmx256M -Xms128M" # small test server!
$ bin/kafka-server-start.sh config/server.properties
--> ...

我为远程计算机上的生产者打开了防火墙,并创建了一个新主题并对其进行了验证:

$ bin/kafka-topics.sh --create --zookeeper MY.EXTERNAL.IP:2181 --replication-factor 1 --partitions 1 --topic test123
--> Created topic "test123".
$ bin/kafka-topics.sh --list --zookeeper MY.EXTERNAL.IP:2181
--> test123

但是,我正在远程运行的生产者给了我错误:

$ bin/kafka-console-producer.sh --broker-list MY.EXTERNAL.IP:9092 --topic test123
--> [2015-06-16 14:41:19,757] WARN Property topic is not valid (kafka.utils.VerifiableProperties)
My Test Message
--> [2015-06-16 14:42:43,347] WARN Error while fetching …