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>
Sat, 2 Nov 2024 08:43:13 +0000 (09:43 +0100)
commit8134088c9f0df31c707fcd6bb18a87822d1b1466
tree29022b57a0d2325a3e4cc2cbc362a5ddd70c06cf
parent3d6b01fa86693e8bb40cb058c1c09155642bb401
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