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, 29 Nov 2024 09:34:03 +0000 (10:34 +0100)
commit7ca1ac921891a055fe649fd937fdbdf52a201a53
treea00b741ff0bda3b259a11ab171d6a5884355c66a
parentf9ae9ed164ec08937545d5478e7b24b215b7a0ec
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