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>
Fri, 24 Jan 2025 19:19:09 +0000 (20:19 +0100)
commit6e43eb271a3a422aa1f0bb94a41e647d076050c3
tree93e2bf7877a44963730a1c6b545263c2d0338b9c
parenteb733d41980aef7f8b0372defd518a88bcc7b6a3
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