Loading
Salesforce から送信されるメールは、承認済ドメインからのみとなります続きを読む

コンシューマーが自動パーティション割り当ての有効なグループに属していないため、オフセットコミットを完了できません。コンシューマーはグループから除外された可能性があります。

公開日: Dec 28, 2025
解決策
問題

Kafka Listener で次のエラーが発生しました。

********************************************************************************
メッセージ:コンシューマーが自動パーティション割り当ての有効なグループに属していないため、オフセットコミットを完了できません。コンシューマーはグループから除外された可能性があります。
要素: map-and-store-flow/source @ am-bookings-esb-v1-stg:am-bookings-esb.xml:14 (メッセージリスナー)
要素 DSL :
エラータイプ:MULE:SOURCE_RESPONSE_SEND
FlowStack:
ペイロードタイプ: java.util.List
--------------------------------------------------------------------------------

原因

上記のメッセージは、マイクロサービスがオフセットをコミットするまでに長時間かかったときのログです。この問題の背景を理解していただくために、まずコンテキストを説明します。サービス B によって公開される REST API を呼び出す専用のサービス A があります。A は Kafka からメッセージを受信するたびにサービス B の API を呼び出します。B の API がダウンしている場合、Aは 何度か再試行を繰り返します。再試行に時間がかかりすぎると、サービス A の Kafka コンシューマーがコンシューマーグループから削除されます。

コンシューマーグループのコンシューマーやメンバーを管理する、グループコーディネーターと呼ばれるコンポーネントがあります。最後の poll が x ミリ秒を超え、x > max.poll.interval.ms の場合、グループコーディネーターはコンシューマーがダウンしたと判断し、コンシューマーをグループから削除します。そのため、再試行に max.poll.interval.ms を超える時間がかかると、コンシューマーはオフセットをコミットできなくなります。さらに悪いことに、別のコンシューマーが同じメッセージをポーリングして、同じ問題が発生する場合があります。

ソリューション
再試行にかかる時間が「max.poll.interval.ms」を超えないようにします。再試行が 3 回、間隔が 1000 ミリ秒であると仮定すると、「max.poll.interval.ms」の値は
3*1000 ミリ秒、つまり 3000 ミリ秒より大きくならなければなりません。
.
ナレッジ記事番号

001119219

 
読み込み中
Salesforce Help | Article