Storm - KeeperException

Question

我正在運行一個風暴集羣。我有一個靈活的，動物園管理員，卡夫卡服務器和一個節點上的主管， 和另一個節點中的主管。

當我在第一個節點中部署具有簡單Kafka-spout的拓撲時。第二個節點中的管理員拋出運行時異常。

但它在第一個節點中的管理員正常工作。如何解決這個問題？

Answer 1

讓我問一些關於你的拓撲結構的問題： 1.你如何確保水嘴執行器只在第一個管理器節點上運行？它可以在任何主管節點上運行。 2. Supervisor節點在羣集中正確註冊？我的意思是這個節點顯示在UI上？因爲根據例外情況，似乎zookeeper不知道這個節點。 3.如果spout在第一個管理節點上運行，則意味着像「hosthost」這樣的kafka config參數可能已被指定。所以當噴口在第一個節點上運行時，它只爲kafka隊列聯繫本地主機。如果噴口試圖在第二個管理節點上運行，它會失敗，因爲對於他來說，「localhost」本身並不存在kafka queu。

--Hariprasad

Answer 2

我在0.6.2之前遇到過與Storm版本類似的問題。我們嘗試在單獨的節點上運行Zookeeper，問題已解決，但我們很快升級了我們的Storm版本，不再面臨問題。嘗試在單獨的節點上運行Zookeeper並查看是否有幫助。同時檢查您是否正確配置了集羣中的主管。檢查此Google Groups Thread以查看您是否有正確的配置選項。