kafka+动物园管理员远程=错误

Question

我正在尝试安装一个kafka&远程服务器上的zookeeper实例。实际上，我只需要每个节点的一个节点，因为我只想提供用于测试目的的远程kafka。

Kafka和Zookeeper是从Apache Kafka tarball（v0.0.9）运行的，位于Docker镜像中。

尝试使用提供的脚本消费/生产。并尝试使用自己的java应用程序进行生产。如果Kafka&ZK安装在本地服务器上。

这是我在尝试生产时遇到的错误：

BrokerPartitionInfo:83 - Error while fetching metadata [{TopicMetadata for topic RSS ->
No partition metadata for topic RSS due to kafka.common.LeaderNotAvailableException}] for topic [RSS]: class kafka.common.LeaderNotAvailableException

测试的Kafka特性

第一：

borker.id=0
port=9092
host.name=<external-ip>
zookeeper.connect=localhost:<PORT>

第二：

borker.id=0
port=9092
host.name=<external-ip>
zookeeper.connect=<external-ip>:<PORT>

第三：

borker.id=0
port=9092
host.name=<external-ip>
zookeeper.connect=<external-ip>:<PORT>
advertised.host.name=<external-ip>
advertised.host.port=<external-ip>

上一篇：

borker.id=0
port=9092
host.name=</etc/host name>
zookeeper.connect=<external-ip>:<PORT>
advertised.host.name=<external-ip>
advertised.host.port=<external-ip>

这是我的"/etc/hosts"

127.0.0.1 kafka kafka
127.0.0.1 localhost  

我遵循了Getting Started，如果我理解的话，它是localhost/signle服务器配置。我不明白我必须做什么才能用远程通话完成这项工作。。。

谢谢你的帮助！

---

编辑1

host.name=localhost
advertised.host.name=politik.cm-cloud.fr

似乎允许本地消费者（在服务器上）和生产者。但如果我们想在远程服务器上做同样的事情，我们会得到

[2015-12-09 12:44:10,826] WARN Session 0x0 for server null, unexpected error, closing socket connection and attempting reconnect (org.apache.zookeeper.ClientCnxn)
java.net.NoRouteToHostException: No route to host

Answer 1

该错误看起来不像Zookeeper/Kafka的连接问题。只需按照"快速启动"中的说明http://kafka.apache.org/

BrokerPartitionInfo:83 - Error while fetching metadata [{TopicMetadata for topic RSS ->

此外，该错误表示没有分区信息，即主题尚未创建。尝试先创建主题，然后尝试生成/消费，因为当生成不存在的主题时，kafka将基于server.properties中的auto.create.topics.enable创建主题，但远程创建主题比依赖自动创建更好