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>
Sun, 24 Jul 2022 18:30:43 +0000 (20:30 +0200)
commitd5d22ba36600358d96b2b3e65a7324dac2688057
tree205dd6942806395fee034d8bcf26bd69b131163c
parent1407cf25602507e608b9ad64b84f19a8e6945896
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