Das Speichern der Daten und Offsets erfolgt nicht mehr nach jedem `poll()`
authorKai Moritz <kai@juplo.de>
Sun, 24 Jul 2022 16:39:05 +0000 (18:39 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 12 Aug 2022 14:44:56 +0000 (16:44 +0200)
commitd675a67e01107b52240abbe62820aa1c8519f88d
treec98e30eeb714b3e7a99b92974438d00dab456999
parent6ded138c6b8139da2cdc13f2380b5f5a4e51cc4e
Das Speichern der Daten und Offsets erfolgt nicht mehr nach jedem `poll()`

* Statdessen kann eine `Duration` konfiguriert werden.
* Ähnlich wie in der Client-Library von Kafka, wird ein Zeitstempel für
  den letzten Commit gespeichert und die Daten werden immer dann
  gespeichert, wenn dieser weiter als das eingestellte
  `consumer.commit-interval` in der Vergangenheit liegt.
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/java/de/juplo/kafka/ApplicationProperties.java
src/main/java/de/juplo/kafka/EndlessConsumer.java
src/main/resources/application.yml
src/test/java/de/juplo/kafka/ApplicationTests.java