Im `ConsumerRebalanceListener` _muss_ `commitSync()` verwendet werden
authorKai Moritz <kai@juplo.de>
Tue, 23 Aug 2022 16:43:55 +0000 (18:43 +0200)
committerKai Moritz <kai@juplo.de>
Fri, 26 Aug 2022 10:52:44 +0000 (12:52 +0200)
commit5bf8218d4a79a3b55056bffb2ed0c91c6bec8917
tree8f5d32f1197d0ac78ff159acf3fbefd452ae4dd5
parent12c1ce703ef76b75d995f94d1689c894dde1406a
Im `ConsumerRebalanceListener` _muss_ `commitSync()` verwendet werden

* Genaugenommen ist auch `commitAsync()` möglich.
* Es ist jedoch nicht möglich, wie hier zuvor implementiert, `commitAsync()`
  mit einem `OffsetCallback` aufzurufen, in der Zwischenzeit die restlichen
  Aufräumarbeiten durchzuführen und anschließend auf den Callback zu warten.
* Grund: Die Callbacks werden von Kafka nicht direkt aufgerufen, wenn die
  Ergebnisse eintreffen, sondern erst, wenn das nächste mal `poll()`
  aufgerufen wird.
src/main/java/de/juplo/kafka/ApplicationRebalanceListener.java