Fix & Refactor: Restore-Behandlung wurde _allen_ aktiven Partitionen zuteil
authorKai Moritz <kai@juplo.de>
Sat, 2 Nov 2024 14:03:10 +0000 (15:03 +0100)
committerKai Moritz <kai@juplo.de>
Fri, 24 Jan 2025 19:19:09 +0000 (20:19 +0100)
commit925fd0b9030abbad6645224371585e3fcee93c66
tree9723ece3a32b8d0b3551ae1517c976d2733750f8
parent1a5f2e72bba29b538ce2b266903e11e9d49911a1
Fix & Refactor: Restore-Behandlung wurde _allen_ aktiven Partitionen zuteil

* Durch das vorausgehende Refactoring wurde deutlich, dass die Behandlung,
  die den _neu_ hinzugefügten Partitionen zugedacht war, allen in
  `assignedPartitions` vermerkten Partitionen wiederfahren ist.
* Dies ist für den aktuellen Entwicklungsstand ggf. egal, da der wegen dem
  Co-Partitioning (noch!) benötigte `RangeAssignor` eh _zuerst alle_
  Partitionen entzieht, bevor er _dann alle_ neu zuteilt.
* Da der Code aber auch mit dem neuen Consumer-Rebalance Protokoll
  funktionieren muss, wurde das Refactoring hier fortgeführt und so
  vollendet, dass nun _alle_ Aktionenen _nur noch_ von den Callbacks
  `onPartitionsAssigned()` und `onPartitionsRevoked()` ausgeht.
src/main/java/de/juplo/kafka/ExampleConsumer.java