From: Kai Moritz <kai@juplo.de>
Date: Sun, 28 Jan 2024 18:08:40 +0000 (+0100)
Subject: WIP: shard assigned/revoked events
X-Git-Tag: rebase--2024-02-03--15-10~3
X-Git-Url: http://juplo.de/gitweb/?a=commitdiff_plain;h=8bb99af9bf76b178bb5ede537d83713e294a3287;p=demos%2Fkafka%2Fchat

WIP: shard assigned/revoked events
---

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?
       }
     }));
   }