Rückbau auf einen Consumer, der in `onPartitionsRevoked()` immer committed
authorKai Moritz <kai@juplo.de>
Sun, 28 Aug 2022 13:59:54 +0000 (15:59 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 2 Sep 2022 03:31:49 +0000 (05:31 +0200)
commit5805651c16e07a0710b88c2822894941f67c313e
treed9890cce2eda99a4997d08fff7fdac8c6b7d7771
parent627763878b235ba168c7f55a1ef448851b027bfc
Rückbau auf einen Consumer, der in `onPartitionsRevoked()` immer committed

* Entfernt wird hier das erweiterte Interface, für den Rebalance-Listener
  über den die Consumer-Implementierung die Commits für den Fehlerfall
  explizit deaktivieren kann.
* Die Staffelübergabe sollte damit weiterhin normal funktionieren. D.h.,
  solange der Consumer ordentlich heruntergefahren wird und nicht ein
  besonders hohes Nachrichten-Aufkommen angelegt wird.
* Vorführ-Skript so angepasst, dass deutlich wird, dass die
  "Staffelübergabe" nun funktioniert, wenn Consumer ordentlich gestopped
  werden, aber weiterhin Fehler auftreten, wenn ein Consumer
  außerordentlich beendet (hier: getötet) wird.
README.sh
src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java
src/main/java/de/juplo/kafka/EndlessConsumer.java
src/main/java/de/juplo/kafka/RebalanceListener.java [deleted file]
src/test/java/de/juplo/kafka/GenericApplicationTests.java