我試圖在遠程服務器上安裝一個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