Der Zustand des Zählers wird in einem compacted Topic abgelegt
authorKai Moritz <kai@juplo.de>
Mon, 28 Oct 2024 08:39:10 +0000 (09:39 +0100)
committerKai Moritz <kai@juplo.de>
Mon, 28 Oct 2024 13:49:59 +0000 (14:49 +0100)
commit60a1f94506106759fa53e9957f85c2620e0a024b
treeb5e2a1391490f22a64ce0d5ec4a12c2fe58f46e1
parentd9d72609e99a9c3bb2559a4d59d4f9f2e218a679
Der Zustand des Zählers wird in einem compacted Topic abgelegt

* Der Consumer zählt, welche Nachrichten gesendet und welche bestätigt
  wurden.
* Über einen `Phaser` wird sichergestellt, dass alle Nachrichten von den
  zuständigen Brokern bestätigt wurden, bevor der nächste ``poll()``-Aufruf
  erfolgt.
docker/docker-compose.yml
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/java/de/juplo/kafka/ApplicationProperties.java
src/main/java/de/juplo/kafka/ExampleConsumer.java
src/main/resources/application.yml
src/test/java/de/juplo/kafka/ApplicationTests.java