1

kafka(wurstmeister/kafka-docker)用のドッカー画像を作成しました。ドッカーコンテナの内部では、トピックの作成、メッセージの生成、組み込みのシェルスクリプトを使用したメッセージの消費が可能です。今私はhttps://github.com/mapr-demos/kafka-sample-programsでホストされているコードを使用して、私のホストマシンからkafkaブローカーに接続しています。プログラムをビルドして実行した後、何も起こらずにプログラムが停止します。私はproducer.sendがkafkaブローカーに接続できないと思います。どんな助けにも感謝しますプロデューサー/コンシューマーのJavaコードがドッカーセットアップでkafkaに接続できません

+0

ネットワーク上の問題であるかどうかを確認するために、zookeeper/brokerが実行されているポートをtelnetで試すことができますか?これを行うには、「telnet 2181」と「telnet 9092」と入力します。 –

+0

@ jose.goncabel私はtelnet zookeeperできますが、私のホストマシンからはブローカーではありません。これを修正する方法 – maverick

+0

私はあなたのお手伝いをしたいと思いますが、Dockerネットワーキングに関するこれまでの経験はありません。しかし、あなたの疑問を書き直して、あなたの構造がどのように見えるかを明確にすることをお勧めします。動物園飼い主、ブローカー、消費者、生産者が稼動している場所、ドッキング・コンテナ内またはドッキング・コンテナ内。 –

答えて

1

そのプロジェクトのconsumer.propertiesproducer.propertiesファイルの両方がbootstrap.servers=localhost:9092であることがわかります。あなたがlocalhost:9092を使用してdockerizedカフカサービスに接続することはできませんので

、あなたは(あなたのコンテナの名前がkafkaであると仮定して)、例えば、使用することによって、docker inspect kafka | grep IPAをドッキングウィンドウコンテナのIPアドレスを見つけてみてください。次に、localhostをその2つのプロパティファイルのIPアドレスに置き換えます。

1

私はチェス/カフカドッカー画像を使用しています。 KAFKA_ADVERTISED_HOST_NAMEの説明をご覧ください。

関連する問題