Skip to content

Commit

Permalink
add logs.
Browse files Browse the repository at this point in the history
  • Loading branch information
hoseinaghaei committed Feb 15, 2024
1 parent 512fbd4 commit 0e3df39
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions kafka_server/broker/file/read.py
Original file line number Diff line number Diff line change
Expand Up @@ -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:
Expand Down

0 comments on commit 0e3df39

Please sign in to comment.