2016-03-26 8 views
0

3ノードのクラスタ(Googleクラウド)を作成しました。 Zookeeperはすべてのノードで実行されており、私はスレーブノードの1つでKafkaを開始しました。私はクラスタ上のどのマシンからでも通信(公開/消費)できますが、リモートマシンから接続しようとすると、NoBrokersAvailable例外が発生します。Kafka - リモートブローカとの接続失敗 - NoBrokersAvailable

私はテストのためにファイアウォールにポートを開いています。私は、Kafkaの設定でadvertised_hostとportを使いこなしてみましたが、接続できません。

予想される設定は何ですか? - 適切なデフォルトを設定すると、設定が内部とリモートの両方のケースで機能することが期待されましたが、そうではありません。私はzookeeper/kafkaの設定のどの部分が私にこれを微調整することができるかわからない。 何をする必要がありますか?

+0

にそれができただけではあまりにも多くのものがありますが、同じ問題に私の答えを確認してください例えば、マシンは 'iptables'を実行することができます。あるいは、ZookeeperとKafkaはルーティング不可能なIPアドレス(例えば、「10.x.x.x1」や「192.168.x.x」)を聞いているか、それが何であるかを知っているかもしれません。 –

+0

Davidに感謝します。注目される。私はネットワーキングに目を向けるつもりです。もし私が(今まで)それの底に到達していれば、私はここで記録に留意します。 – ismisesisko

+0

更新が、喜びはありません:私は問題を簡略化しました。私は動物園とカフカで1つのノードを使用しました。私はいくつかの利点を提供するコンフルエントなカフカディストリビューションを使用しました。私はZookeeperを検証するRESTサーバーをローカルに、リモートでテストしました。これは適切に設定されており、残りのサーバーに外部接続することができます。私はKafkaを起動すると、出力行に注意します:>登録されたブローカ0のアドレス/ PLANTEXT - > EndPoint(クラスタ3-m、9092、PLAINTEXT)のパス/ブローカ/ ID/0。 「cluster-3-m」と言うと、私は主にPUBLIC IPを使っています。明らかに、ブローカーは起動されバインドされています。 – ismisesisko

答えて