From 8bb99af9bf76b178bb5ede537d83713e294a3287 Mon Sep 17 00:00:00 2001
From: Kai Moritz <kai@juplo.de>
Date: Sun, 28 Jan 2024 19:08:40 +0100
Subject: [PATCH] WIP: shard assigned/revoked events

---
 .../chat/backend/implementation/kafka/InfoChannel.java | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java
index f28a1e7d..cf4d03c2 100644
--- a/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java
+++ b/src/main/java/de/juplo/kafka/chat/backend/implementation/kafka/InfoChannel.java
@@ -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?
       }
     }));
   }
-- 
2.20.1