0

問題を解決するためのバリアントを探しています。テストでは、2 つのパーティションを持つ 1 つのトピックがあります。このトピックでは、2 つのコンシューマーを作成し、サブスクライブしました。すべてのコンシューマーには、ce24f096-2709-4e0a-946a-61ca6cb64780 や 22ba2c2a-66cb-4da0-97be-2570a731ae2c のような UUID があります。消費者によるメッセージの取得には、http://rest-proxy:8082/consumers/consumer-group/instances/consumer1/records および http://rest-proxy:8082/consumers/consumer-group/instances/consumer2 のような URL を使用します/記録。2 番目のコンシューマーと MAX_SESSION_TIMEOUT_MS グループが再調整された後、1 つのコンシューマーが両方のパーティションからメッセージを読み取り、正常に予測どおりにします。2 番目のコンシューマーを起動した後、トピックからメッセージを取得しようとすると、エラーコンシューマー インスタンスが見つかりません、削除したため。グループから消費者を長時間削除しないで、2 番目の消費者が 5 分間要求しない場合、グループのバランスを取り直すにはどうすればよいと思いますか。到達可能になった後にメッセージを取得できます。

4

0 に答える 0