Fix: `poll()` liefert nicht immer Nachrichten zu _allen_ Partitionen
authorKai Moritz <kai@juplo.de>
Mon, 28 Oct 2024 10:16:12 +0000 (11:16 +0100)
committerKai Moritz <kai@juplo.de>
Sun, 10 Nov 2024 13:27:08 +0000 (14:27 +0100)
commit1b2ce7758072891cd98ad1344e6808f59b08fbd8
treea27ed66fb77af874c5b00eefb4f4d290bf88e5aa
parent7c590617a9b3f7e669ea2652d2c76c15be51d13e
Fix: `poll()` liefert nicht immer Nachrichten zu _allen_ Partitionen

* Ein Aufruf von `poll()` liefert _nicht unbedingt_ Nachrichten zu _jeder_
  Partition, die der Instanz gerade zugeteilt ist.
* Daher konnte es auftreten, dass eine Phase nie beendet wurde, wenn
  `poll()` nur Nachrichten zu einer Untermenge der aktiven Partitionen
  geliefert hat.
src/main/java/de/juplo/kafka/ExampleConsumer.java