projects / demos / kafka / training / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: ce840f4) | 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>
Fri, 12 Aug 2022 14:44:56 +0000 (16:44 +0200)
commit6ded138c6b8139da2cdc13f2380b5f5a4e51cc4e
tree29f5f14e5970eb58d74a88631b3bc31f96dd6a05tree | snapshot
parentce840f48340d55613291fca468bf10b834c473dbcommit | 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.