我正在试图在远程服务器上安装kafka &实例。实际上,我只需要每个节点中的一个节点,因为我只想为测试目的提供远程kafka。
卡夫卡和动物园管理员正在从Apache中运行,您可以找到那里 (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/host”
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发布于 2015-12-21 11:02:21
这个错误看起来不像/ Kafka的连接问题。只需按照http://kafka.apache.org/的“快速启动”中的指示操作即可。
BrokerPartitionInfo:83 - Error while fetching metadata [{TopicMetadata for topic RSS ->此外,错误指示没有分区信息,即主题尚未创建。先尝试创建主题,然后尝试生成/消费,因为当生成一个不存在的主题时,kafka将在server.properties中基于server.properties创建主题,但远程创建主题比依赖自动创建要好。
https://stackoverflow.com/questions/34176970
复制相似问题