Wie Offset in kafkalisten

Question

setzen

Ich versuche, Daten von Kafka Server zu konsumieren, verwende ich @Kafkalistener Annotation.

Das Problem ist, dass ich alle Nachrichten jedes Mal bekomme, wenn ich meine Anwendung neu starte. Wie speichere ich den letzten verbrauchten Offset in meiner Anwendung und verwende ihn, um die nächsten Nachrichten zu konsumieren?

Answer 1

Dieses Tutorial hat die Antwort: https://www.codenotfound.com/spring-kafka-boot-example.html

Die kafka.consumer.auto-Offset-Reset-Eigenschaft muss ‚früheste‘ gesetzt werden, die die neue Verbrauchergruppe sorgt für die Meldung geschickt bekommen falls der Container nach dem Senden gestartet wurde.

So sollten Sie es spätestens nach Ihren Anforderungen einstellen