fix.

mahdigheidi · Feb 15, 2024 · 3f2f87f · 3f2f87f
1 parent da19c4b
commit 3f2f87f
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/kafka_server/broker/file/sync.py b/kafka_server/broker/file/sync.py
@@ -44,6 +44,7 @@ def sync_data(self):
             broker_id = int(md5, 16) % partition_count
             if broker_id == (int(self.partition) - 1) % partition_count:
                 self.segment.approve_sync()
+                print("this key is for this partition")
                 return self.sync_data()
             print("send sync data to broker", broker_id)