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, 8 Nov 2024 17:21:16 +0000 (18:21 +0100)
commit5abcc2a99e3e6ff04ce9afcc6f402592f2990b3c
treebc4dd00693114380f40056ef91f1211280e84ad5
parent246eab8a4960140cf4b2ccf32de95f192b523204
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