From 0e3df399ee0751bb30d1c0e8b6d19a8b9f9d03dd Mon Sep 17 00:00:00 2001 From: hoseinaghaei Date: Thu, 15 Feb 2024 04:44:47 +0330 Subject: [PATCH] add logs. --- kafka_server/broker/file/read.py | 1 + 1 file changed, 1 insertion(+) diff --git a/kafka_server/broker/file/read.py b/kafka_server/broker/file/read.py index 4386212..84b663a 100644 --- a/kafka_server/broker/file/read.py +++ b/kafka_server/broker/file/read.py @@ -53,6 +53,7 @@ def toggle_message_in_fly(self): def read_data(self): self.subscribers = self.get_subscribers() if len(self.subscribers) == 0: + print("No subscribers") return None, None self.load_message_in_fly() if self.message_in_fly: