2017-04-06 6 views
0

ホストOSからJavaクライアントからメッセージを取得しようとしました。私は、ホストとゲスト間のブリッジネットワークを構成しカフカが実行されているが、ゲストOSにConsumerRecords<String,String> records = consumers.poll(100); マイカフカをやろうが、ローカルホスト上で聴いたときにJavaクライアントを貼り付けた:9092virtualbox vmでホストしているKafkaからメッセージを取得する方法

答えて

0

あなたが消費者のプロパティを共有してもらえますか?

ファイルに検証するプロパティがいくつかあります:listenersadvertised.listenersです。あなたはこれを確認することができます:https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-Whycan 'tmyconsumers /プロデューサはブローカーを接続しますか?

関連する問題