add log on error.

mahdigheidi · Feb 15, 2024 · b63f9f0 · b63f9f0
1 parent 0c14213
commit b63f9f0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/kafka_server/broker/file/read.py b/kafka_server/broker/file/read.py
@@ -140,6 +140,7 @@ def get_subscribers():
 
         with open(subscriptions_file_path, 'r', encoding='utf8') as f:
             subscribers = json.load(f)
+            print("Found {} subscribers".format(subscribers))
 
         return subscribers
 
@@ -164,7 +165,10 @@ def choose_subscriber(self):
         id_to_key = {}
         for i, key in enumerate(self.subscribers.keys()):
             id_to_key[i] = key
+
+        print("id_to_key", id_to_key)
         chosen_key = id_to_key[read_index % subscriber_count]
+        print("chosen_key", chosen_key)
         return chosen_key, self.subscribers[chosen_key]
 
     def load_message_in_fly(self):