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, 8 Nov 2024 17:21:16 +0000 (18:21 +0100)
commit6afadf5b92567c896a750af492a8e3cff71769ba
tree3e8fffb9e4d4f07c17e7d5aad52d325050b90495
parent9339a4c3cf18023135a6a89b5c09446f59b59fe3
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