sync replica up.

mahdigheidi · Feb 15, 2024 · 187571f · 187571f
1 parent 84c712f
commit 187571f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/kafka_server/broker/main.py b/kafka_server/broker/main.py
@@ -51,9 +51,9 @@ def init():
     heartbeat_thread.daemon = True
     heartbeat_thread.start()
 
-    # sync_thread = threading.Thread(target=schedule_sync_thread)
-    # sync_thread.daemon = True
-    # sync_thread.start()
+    sync_thread = threading.Thread(target=schedule_sync_thread)
+    sync_thread.daemon = True
+    sync_thread.start()
 
     sync_replica_thread = threading.Thread(target=sync_replica)
     sync_replica_thread.daemon = True