diff --git a/tests/script/tsim/tmq/basic1.sim b/tests/script/tsim/tmq/basic1.sim
index 80e048a9e4..4ef0c121f6 100644
--- a/tests/script/tsim/tmq/basic1.sim
+++ b/tests/script/tsim/tmq/basic1.sim
@@ -62,7 +62,7 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
+$keyList = $keyList . ,
 $keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
diff --git a/tests/script/tsim/tmq/basic1Of2Cons.sim b/tests/script/tsim/tmq/basic1Of2Cons.sim
index 76e9775fc9..d2906ec875 100644
--- a/tests/script/tsim/tmq/basic1Of2Cons.sim
+++ b/tests/script/tsim/tmq/basic1Of2Cons.sim
@@ -62,7 +62,7 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
+$keyList = $keyList . ,
 $keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
diff --git a/tests/script/tsim/tmq/basic2.sim b/tests/script/tsim/tmq/basic2.sim
index 57bcb40921..4477101d0f 100644
--- a/tests/script/tsim/tmq/basic2.sim
+++ b/tests/script/tsim/tmq/basic2.sim
@@ -62,7 +62,7 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
+$keyList = $keyList . ,
 $keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
diff --git a/tests/script/tsim/tmq/basic2Of2Cons.sim b/tests/script/tsim/tmq/basic2Of2Cons.sim
index 44b6a4b591..951a1d52fd 100644
--- a/tests/script/tsim/tmq/basic2Of2Cons.sim
+++ b/tests/script/tsim/tmq/basic2Of2Cons.sim
@@ -62,7 +62,7 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
+$keyList = $keyList . ,
 $keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
diff --git a/tests/script/tsim/tmq/basic2Of2ConsOverlap.sim b/tests/script/tsim/tmq/basic2Of2ConsOverlap.sim
index b279a13826..8cc447f0c7 100644
--- a/tests/script/tsim/tmq/basic2Of2ConsOverlap.sim
+++ b/tests/script/tsim/tmq/basic2Of2ConsOverlap.sim
@@ -62,7 +62,7 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
+$keyList = $keyList . ,
 $keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
diff --git a/tests/script/tsim/tmq/basic3.sim b/tests/script/tsim/tmq/basic3.sim
index b66917623e..da2bee4f6b 100644
--- a/tests/script/tsim/tmq/basic3.sim
+++ b/tests/script/tsim/tmq/basic3.sim
@@ -62,7 +62,7 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
+$keyList = $keyList . ,
 $keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
diff --git a/tests/script/tsim/tmq/basic3Of2Cons.sim b/tests/script/tsim/tmq/basic3Of2Cons.sim
index 6284356e91..21d691bd9c 100644
--- a/tests/script/tsim/tmq/basic3Of2Cons.sim
+++ b/tests/script/tsim/tmq/basic3Of2Cons.sim
@@ -62,7 +62,7 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
+$keyList = $keyList . ,
 $keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
diff --git a/tests/script/tsim/tmq/basic4.sim b/tests/script/tsim/tmq/basic4.sim
index 290d611cbc..adeab58ff2 100644
--- a/tests/script/tsim/tmq/basic4.sim
+++ b/tests/script/tsim/tmq/basic4.sim
@@ -62,7 +62,7 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
+$keyList = $keyList . ,
 $keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
diff --git a/tests/script/tsim/tmq/basic4Of2Cons.sim b/tests/script/tsim/tmq/basic4Of2Cons.sim
index 0a3b4d2ee0..186005b231 100644
--- a/tests/script/tsim/tmq/basic4Of2Cons.sim
+++ b/tests/script/tsim/tmq/basic4Of2Cons.sim
@@ -62,7 +62,7 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
+$keyList = $keyList . ,
 $keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
diff --git a/tests/script/tsim/tmq/snapshot.sim b/tests/script/tsim/tmq/snapshot.sim
index fbdaba7d28..c0194d98c8 100644
--- a/tests/script/tsim/tmq/snapshot.sim
+++ b/tests/script/tsim/tmq/snapshot.sim
@@ -62,8 +62,8 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
-#$keyList = $keyList . auto.offset.reset:earliest
+$keyList = $keyList . ,
+$keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
 
diff --git a/tests/script/tsim/tmq/snapshot1.sim b/tests/script/tsim/tmq/snapshot1.sim
index 5349981cc7..6121692d6c 100644
--- a/tests/script/tsim/tmq/snapshot1.sim
+++ b/tests/script/tsim/tmq/snapshot1.sim
@@ -62,8 +62,8 @@ $keyList = $keyList . ,
 $keyList = $keyList . enable.auto.commit:false
 #$keyList = $keyList . ,
 #$keyList = $keyList . auto.commit.interval.ms:6000
-#$keyList = $keyList . ,
-#$keyList = $keyList . auto.offset.reset:earliest
+$keyList = $keyList . ,
+$keyList = $keyList . auto.offset.reset:earliest
 $keyList = $keyList . '
 print ========== key list:  $keyList
 
diff --git a/tests/system-test/7-tmq/tmqParamsTest.py b/tests/system-test/7-tmq/tmqParamsTest.py
index ff7c70bcd2..0e9e8f989f 100644
--- a/tests/system-test/7-tmq/tmqParamsTest.py
+++ b/tests/system-test/7-tmq/tmqParamsTest.py
@@ -19,7 +19,7 @@ class TDTestCase:
         self.wal_retention_period1 = 3600
         self.wal_retention_period2 = 1
         self.commit_value_list = ["true", "false"]
-        self.offset_value_list = ["", "earliest", "latest", "none"]
+        self.offset_value_list = ["earliest", "latest", "none"]
         self.tbname_value_list = ["true", "false"]
         self.snapshot_value_list = ["false"]
 
@@ -92,7 +92,7 @@ class TDTestCase:
                         }
                         consumer_commit = 1 if consumer_dict["enable.auto.commit"] == "true" else 0
                         consumer_tbname = 1 if consumer_dict["msg.with.table.name"] == "true" else 0
-                        consumer_ret = "earliest" if offset_value == "" else offset_value
+                        consumer_ret = "latest" if offset_value == "" else offset_value
                         expected_parameters=f'tbname:{consumer_tbname},commit:{consumer_commit},interval:{paraDict["auto_commit_interval"]}ms,reset:{consumer_ret}'
                         if len(offset_value) == 0:
                             del consumer_dict["auto.offset.reset"]
diff --git a/utils/test/c/tmq_taosx_ci.c b/utils/test/c/tmq_taosx_ci.c
index 5d4d73c448..ff89bb1f75 100644
--- a/utils/test/c/tmq_taosx_ci.c
+++ b/utils/test/c/tmq_taosx_ci.c
@@ -547,6 +547,7 @@ tmq_t* build_consumer() {
   tmq_conf_set(conf, "td.connect.pass", "taosdata");
   tmq_conf_set(conf, "msg.with.table.name", "true");
   tmq_conf_set(conf, "enable.auto.commit", "true");
+  tmq_conf_set(conf, "auto.offset.reset", "earliest");
 
   if (g_conf.snapShot) {
     tmq_conf_set(conf, "experimental.snapshot.enable", "true");