2017-04-26 18 views
0

レコードを消費するためにjava classを作成しました。対応するサーバーに接続されていますが、これはローカルマシンからメッセージを消費することができます。 jarファイルを作成していますが、そこから私のサーバーにこのjarファイルを配置しています。私はjava classを実行しています。メッセージを受信して​​いないのにトピックを購読していますが、ローカルでは購読してメッセージを受信して​​います。カフカ消費者はサーバー内のレコードを消費していません

+0

コンシューマがサーバー上で実行されている間に、追加のメッセージをサーバーに出力しようとしましたか? – user2122031

答えて

0

サーバでは、kafkaサーバIPが異なるため、メッセージを消費できません。 kafkaサーバのIPを変更した後、そのIPアドレスが動作しました。

関連する問題