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>
Thu, 6 Feb 2025 16:55:40 +0000 (17:55 +0100)
commit46eeea49ede422b34b7fa846938c33d0fff81696
tree93e2bf7877a44963730a1c6b545263c2d0338b9c
parent1d075ea3a3b7d80add73ed0a7f44cda590674ffe
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