我试图在远程服务器上安装一个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