2015-12-09 61 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更好創建