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>
Sat, 2 Nov 2024 15:12:17 +0000 (16:12 +0100)
commit4da98e04a82284632cd787fd60a3efbc174c034d
tree7d9b204d3f401e0cb588ef337b0a8d9b9ce88ca3
parent127d62c9bebc408da677d9c2ba3e7381cadb424f
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