Loading

Die Offset-Zuweisung kann nicht abgeschlossen werden, da der Verbraucher nicht Teil einer aktiven Gruppe für automatische Partitionszuweisung ist. Es ist wahrscheinlich, dass der Verbraucher aus der Gruppe ausgeschlossen wurde.

Veröffentlichungsdatum: Dec 28, 2025
Lösung
SYMPTOM

Der folgende Fehler tritt bei Kafka Listener auf -

********************************************************************************
Message: Offset commit cannot be completed since the consumer is not part of an active group for auto partition assignment; it is likely that the consumer was kicked out of the group. (Meldung: Die Offset-Zuweisung kann nicht abgeschlossen werden, da der Verbraucher nicht Teil einer aktiven Gruppe für automatische Partitionszuweisung ist. Es ist wahrscheinlich, dass der Verbraucher aus der Gruppe ausgeschlossen wurde.)
Element : map-and-store-flow/source @ am-bookings-esb-v1-stg:am-bookings-esb.xml:14 (Message listener)
Element DSL :
Error type: (Fehlertyp:) MULE:SOURCE_RESPONSE_SEND
FlowStack :
Payload Type : java.util.List
--------------------------------------------------------------------------------

URSACHE

Die obige Meldung stammt aus dem Protokoll, wenn der Microservice viel Zeit in Anspruch nimmt, bevor der Offset übernommen wird. Lassen Sie uns zunächst den Kontext erklären, um Ihnen einige Hintergrundinformationen zu dem Thema zu geben. Ich habe Service A so eingerichtet, dass er die von Service B offengelegte REST-API aufruft. Immer wenn A eine Nachricht von Kafka erhält, ruft es die API von Service B auf. Wenn B außer Betrieb ist, unternimmt A weiterhin mehrere Versuche. Wenn der Wiederholungsversuch zu lange dauert, wird der Kafka-Verbraucher von Service A aus der Verbrauchergruppe entfernt.

Es gibt eine Komponente mit dem Namen "Gruppenkoordinator", die Verbraucher/Mitglieder von Verbrauchergruppen verwaltet. Wenn die letzte Abstimmung länger als x ms dauert und x > max.poll.interval.ms ist, geht der Gruppenkoordinator davon aus, dass der Verbraucher verstorben ist, und entfernt ihn aus der Gruppe. Wenn die Wiederholung länger dauert als das max.poll.interval.ms, kann der Verbraucher den Offset nicht festlegen. Oder noch schlimmer: Ein anderer Verbraucher könnte dieselbe Nachricht abrufen und auf dasselbe Problem stoßen.

LÖSUNG
Stellen Sie sicher, dass der Wiederholungsversuch nicht länger dauern kann als "max.poll.interval.ms". Nehmen wir an, es gibt drei Wiederholungsversuche und das Intervall beträgt 1000 ms, dann sollte der Wert des "max.poll.interval.ms"
größer als 3 x 1000 ms, also mehr als 3000 ms sein.
.
Nummer des Knowledge-Artikels

001119219

 
Laden
Salesforce Help | Article