2015-12-09 44 views
0

我试图在远程服务器上安装一个kafka & zookeeper实例。我只需要每个实际节点中的1个节点,因为我只想为测试目的提供远程kafka。kafka + zookeeper remote =错误

Kafka和Zookeeper从Apache Kafka tarball运行,您可以找到there(v0.0.9),在Docker镜像中运行。

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

这是我得到的,而试图产生错误:

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 

卡夫卡性能测试

第一:

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 

我跟着入门,而如果我的理解是本地主机/劲儿服务器配置。我不明白我必须做什么才能使用远程调用进行此项工作...

感谢您的帮助!


编辑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 

回答

0

错误并不像与动物园管理员/卡夫卡连接问题。 只需按照“快速开始”的指令从http://kafka.apache.org/

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

此外,该错误表示目前还没有创建任何分区信息,即话题。尝试先创建主题,然后尝试产生/消费,因为当产生一个不存在的主题时,kafka将根据server.properties中的auto.create.topics.enable创建主题,但远程创建主题​​比依赖auto更好创建