Implementierung vereinfacht: Auf das Nötigste zusammengekürzt
authorKai Moritz <kai@juplo.de>
Sun, 21 Aug 2022 17:33:11 +0000 (19:33 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 26 Aug 2022 10:48:31 +0000 (12:48 +0200)
commit2d25525ef70a90709edc48bd9542d1b08a2888a2
treeecb17c315c9eb1128b89b70397582b854d08997b
parentbfddb34a846a27a477d97eaa4db9221afbd6dbba
Implementierung vereinfacht: Auf das Nötigste zusammengekürzt

* Das regelmäßige Speichern im Poll-Interval wird für die Übung nicht
  benötigt.
* Damit entfällt auch das Interface
  `PollIntervalAwareConsumerRebalanceListener`
* Die Vereinfachung hat eine Anpassung der Tests erfordert: Da in dem
  Test, der überprüft, ob die Offsets korrekt committed werde, wenn kein
  Fehler vorliegt, gar kein Rebalance auftritt, musste der Consumer
  gestoppt werden, damit die Ergebnisse für die Überprüfung sichtbar
  werden.
src/main/java/de/juplo/kafka/ApplicationConfiguration.java
src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
src/main/java/de/juplo/kafka/EndlessConsumer.java
src/main/java/de/juplo/kafka/PollIntervalAwareConsumerRebalanceListener.java [deleted file]
src/test/java/de/juplo/kafka/GenericApplicationTests.java