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>
Fri, 24 Jan 2025 19:19:09 +0000 (20:19 +0100)
commit432b41bdb5b977fde687336b521f01052a3a5bad
tree1cb206cff07a22fc1407e7c6e68e5e9eee445010
parentff5a6df91ff25b40db1848c18a40069b122b6179
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