2016-06-29 7 views
1

ich oft Problem sehe, in dem KAFKA Verbraucherstrom wird versetzt und Verzögerung zu unbekannt
Frühere Verbraucher gesetzt kompensiert haben und LagOffset und Verzögerung für kafka Verbraucher (über neue Verbraucher api erstellt) werden auf unbekannte

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER 
G.AB_KAFF, T.AB_KAFF, 0, 3, 6, 3, consumer-2 
G.AB_KAFF, T.AB_KAFF, 1, 8, 11, 3, consumer-2 

Als ich diese Verbraucher wieder nach wenigen Tagen abonnierte seine Offset und Verzögerung auf unbekannte

GROUP, TOPIC, PARTITION, CURRENT OFFSET, LOG END OFFSET, LAG, OWNER 
G.AB_KAFF, T.AB_KAFF, 0, unknown, 7, unknown, consumer-2 
G.AB_KAFF, T.AB_KAFF, 1, unknown, 11, unknown, consumer-2 

vorherigen Offsets kafka Entfernung für diesen Verbraucher festgelegt ist, da ich von Thema ganze Verbrauchergruppe am abzumelden?

Antwort

4

Ist kafka Entfernen von früheren Offsets für diesen Verbraucher seit ich bin Abmeldung der gesamten Verbrauchergruppe von Thema?

Ja, Sie haben Recht. offsets.retention.minutes=1440 (24 hours) Standard ist 24 Stunden.
Protokoll Aufbewahrungsfenster in Minuten für Offsets Thema