]> juplo.de Git - demos/kafka/training/commit
Version des ``spring-consumer``, die zu vorgegebenen Offsets springt consumer/spring-consumer--seek--2026-03--vor-branchumbenennung--springframework consumer/spring-consumer--seek--2026-03-20 consumer/spring-consumer--seek--2026-03-20--19-06
authorKai Moritz <kai@juplo.de>
Sun, 10 Nov 2024 11:10:10 +0000 (12:10 +0100)
committerKai Moritz <kai@juplo.de>
Mon, 16 Mar 2026 20:03:37 +0000 (21:03 +0100)
commit0754164a53e8645824272c12290997e647624e07
treef70bf646751c63e9a2365ea953a49717a06d1de6
parent9ef473db019bf00b68681c46097b82cb79dd5a49
Version des ``spring-consumer``, die zu vorgegebenen Offsets springt

* Die übergebenen Offsets werden bei der Zuteilung der Partitionen
  verarbeitet.
* Anschließend werden die übergebenen Start-Offsets gelöscht, so dass bei
  späteren Rebalances kein erneuter Wechsel der Offset-Position erfolgt.
* Die Anwendung überprüft nicht, ob die Menge der übergebenen Offsets
  vollständig ist, oder zu den zugeteilten Partitionen passt.
* D.h. insbesondere, dass ein Wechsel der Offset-Positionen für eine
  bestimmte Partition ggf. erst später erfolgt, wenn diese Partition einer
  anderen Instanz zugeteilt ist und diese Instanz die Partition erst
  später frei gibt.
* Docker-Setup und `README.sh` zur Vorführung angepasst
README.sh
docker/docker-compose.yml
pom.xml
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/java/de/juplo/kafka/ApplicationProperties.java
src/main/java/de/juplo/kafka/ExampleConsumer.java