sync replica up.

mahdigheidi · Feb 15, 2024 · 84c712f · 84c712f
1 parent c296665
commit 84c712f
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/kafka_server/broker/main.py b/kafka_server/broker/main.py
@@ -55,4 +55,8 @@ def init():
     # sync_thread.daemon = True
     # sync_thread.start()
 
+    sync_replica_thread = threading.Thread(target=sync_replica)
+    sync_replica_thread.daemon = True
+    sync_replica_thread.start()
+
     schedule.run_pending()
diff --git a/kafka_server/broker/read/read_cronjob.py b/kafka_server/broker/read/read_cronjob.py
@@ -14,8 +14,9 @@ def read_sample_data():
     with fetch_lock:
         read_instance = Read(get_primary_partition(), get_replica_url())
 
-        print("reading sample data")
-        print(read_instance.read_data())
+        # print("reading sample data")
+        # print(read_instance.read_data())
+        read_instance.read_data()
 
 
 def schedule_read():