fix.

mahdigheidi · Feb 15, 2024 · 407f70e · 407f70e
1 parent 3f2f87f
commit 407f70e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka_server/broker/file/sync.py b/kafka_server/broker/file/sync.py
@@ -44,7 +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")
+                print(f"this key is for this partition, {md5} {key} {partition_count}")
                 return self.sync_data()
             print("send sync data to broker", broker_id)