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