以下に示すように、1 つのパーティションと 1 つのレプリケーション ファクターのみを持つトピック car があります。
Topic:cars PartitionCount:1 ReplicationFactor:1 Configs:
Topic: cars Partition: 0 Leader: 0 Replicas: 0 Isr: 0
ローカルホストの 9092 で 1 つ、9093 で 1 つの 2 つのブローカーを実行しています。
私の Java アプリケーションはトピック cars にメッセージを送信します。非常に奇妙な動作が見られます。
- 私の Java アプリケーションは、メッセージ #1、メッセージ #3 などの代替メッセージしか受信しません。
この問題をデバッグするために、コンソール コンシューマーを開始しました。これで、Java アプリケーションが取得できなかったメッセージのみが表示されました。たとえば、メッセージ #2、メッセージ #4 など
メッセージがトピックに正しく投稿されていることは明らかですが、Java アプリケーションが代替メッセージしか受信しない原因は何ですか?
そして最後に、なぜコンシューマ コンソールは上記の動作しか示さないのですか?