X-Git-Url: https://juplo.de/gitweb/?a=blobdiff_plain;f=src%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Fchat%2Fbackend%2Fimplementation%2Fkafka%2FInfoChannel.java;h=cf4d03c280225405aafe47ff1fd2b023454a6c76;hb=242f7661171468a4898d6c36de367136e75b8bb9;hp=f28a1e7dde4d26d459b50b144387534e76c5f8ef;hpb=f7d262315d1d5b985466bb334a84339f49463e38;p=demos%2Fkafka%2Fchat

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