プロデューサーによって送信された 1 つ以上のパーティションからすべてのメッセージを読み取ることができる 3 つのコンシューマーを作成する必要があるユース ケースがあります。同じメッセージを受信した後、3 つのコンシューマーが 3 つの異なるタスクを実行する必要があります。
これを行う良い方法の 1 つは、異なる group.id を使用してコンシューマー グループを作成することです。
props.put("group.id", UUID.randomUUID().toString())
このアイデアについては、次のリンクを参照しました。
これを達成するために ConsumerGroupExample コードをどのように調整するかを知るのに行き詰まっていますか? 複数のコンシューマーを作成するにはどうすればよいですか? メッセージを受信した後、それらを個別に管理するにはどうすればよいですか? ConsumerGroupExample の複数のオブジェクトを作成する必要がありますか?