diff --git a/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py b/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py
index 8591597a9f..d9e9280fcc 100644
--- a/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py
+++ b/tests/python_client/cdc/perf/milvus_cdc_recovery_perf_test.py
@@ -327,7 +327,7 @@ class MilvusCDCPerformance:
                                 expr=f"timestamp == {latest_insert_ts}",
                                 output_fields=["timestamp"],
                                 limit=1,
-                                consistency_level="Bounded"
+                                consistency_level="Eventually"
                             )
                         except Exception as e:
                             logger.debug(f"Query failed: {e}")
@@ -358,7 +358,7 @@ class MilvusCDCPerformance:
                     expr="",
                     output_fields=["count(*)"],
                     timeout=10,
-                    consistency_level="Bounded"
+                    consistency_level="Eventually"
                 )
                 tt = time.time() - t0
                 self.target_count = results[0]['count(*)']
@@ -373,7 +373,7 @@ class MilvusCDCPerformance:
                     expr="",
                     output_fields=["count(*)"],
                     timeout=10,
-                    consistency_level="Bounded"
+                    consistency_level="Eventually"
                 )
                 tt = time.time() - t0
                 self.source_count = results[0]['count(*)']
@@ -383,7 +383,7 @@ class MilvusCDCPerformance:
         previous_count = self.target_collection.query(
                     expr="",
                     output_fields=["count(*)"],
-                    consistency_level="Bounded"
+                    consistency_level="Eventually"
                 )[0]['count(*)']
         while not self.stop_query:
             try: