projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 25bc939) | patch
Wenn kein gespeicherter Offset vorliegt, auto.offset.reset von Kafka nutzen
authorKai Moritz <kai@juplo.de>
Sun, 24 Jul 2022 16:22:00 +0000 (18:22 +0200)
committerKai Moritz <kai@juplo.de>
Sun, 24 Jul 2022 18:30:43 +0000 (20:30 +0200)
commit1407cf25602507e608b9ad64b84f19a8e6945896
tree6dc8d36551deb60e7640fd2566186ad3aea9d68ctree | snapshot
parent25bc9398e6d81468e9605655e8c36a3caa347401commit | diff
Wenn kein gespeicherter Offset vorliegt, auto.offset.reset von Kafka nutzen

* Es wird jetzt nur noch dann ein expliziter Seek durchgeführt, wenn eine
  gespeicherte Offset-Position gefunden wurde.
* Andernfalls wird der von Kafka initialisierte Ausgansgs-Offset verwendet.
* Welchen Offset Kafka vorgibt, hängt von `auto.offset.rest` ab!
src/main/java/de/juplo/kafka/EndlessConsumer.java diff | blob | history
src/main/java/de/juplo/kafka/StatisticsDocument.java diff | blob | history
Unnamed repository; edit this file 'description' to name the repository.