WIP: shard assigned/revoked events
authorKai Moritz <kai@juplo.de>
Sun, 28 Jan 2024 18:08:40 +0000 (19:08 +0100)
committerKai Moritz <kai@juplo.de>
Sun, 28 Jan 2024 18:08:40 +0000 (19:08 +0100)
src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java

index f28a1e7..cf4d03c 100644 (file)
@@ -134,6 +134,12 @@ public class InfoChannel implements Runnable
             "Could not send shard assigned event for shard {}: {}",
             shard,
             exception);
+        // TODO:
+        // Verhalten im Fehlerfall durchdenken!
+        // Z.B.: unsubscribe() und darauf folgendes (re-)subscribe() des
+        // Consumers veranlassen, so dass die nicht öffentlich Bekannte
+        // Zuständigkeit abgegeben und neu zugeordnet wird?
+        // Falls der Weg gegangen wird: Achtung wegen Sticke Partitions!
       }
     }));
   }
@@ -161,6 +167,10 @@ public class InfoChannel implements Runnable
             "Could not send shard revoked event for shard {}: {}",
             shard,
             exception);
+        // TODO:
+        // Verhalten im Fehlerfall durchdenken!
+        // Ggf. einfach egal, da die neue zuständige Instanz den
+        // nicht gelöschten Eintrag eh überschreibt?
       }
     }));
   }