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>
Tue, 21 Jan 2025 20:25:03 +0000 (21:25 +0100)
commitbbf75ee1046bbb5f120885329773a7ab4cbc8bd8
tree17ffc8e773f977d8a62cf1a9e4052dc9a57095f4
parent018e77e33c0de12a2845f8038f9faf661f9dbe5f
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