diff --git a/tests/system-test/7-tmq/subscribeDb4.py b/tests/system-test/7-tmq/subscribeDb4.py
index 7f5169361c1e3130bef0c29fd8eef1e6837248d8..c14d3b27b11fa8e36bd216f23a2371018358aaf0 100644
--- a/tests/system-test/7-tmq/subscribeDb4.py
+++ b/tests/system-test/7-tmq/subscribeDb4.py
@@ -31,7 +31,8 @@ class TDTestCase:
                 'startTs':    1640966400000,  # 2022-01-01 00:00:00.000
                 'pollDelay':  20,
                 'showMsg':    1,
-                'showRow':    1}
+                'showRow':    1,
+                'snapshot':    1}
 
     cdbName = 'cdb'
     # some parameter to consumer processor
@@ -42,7 +43,7 @@ class TDTestCase:
     ifManualCommit = 1
     groupId = 'group.id:cgrp1'
     autoCommit = 'enable.auto.commit:true'
-    autoCommitInterval = 'auto.commit.interval.ms:1000'
+    autoCommitInterval = 'auto.commit.interval.ms:100'
     autoOffset = 'auto.offset.reset:earliest'
 
     pollDelay = 20
@@ -86,7 +87,7 @@ class TDTestCase:
         tmqCom.insertConsumerInfo(self.consumerId, self.expectrowcnt,topicList,keyList,self.ifcheckdata,self.ifManualCommit)
 
         tdLog.info("start consume processor")
-        tmqCom.startTmqSimProcess(self.pollDelay,self.paraDict["dbName"],self.showMsg, self.showRow,self.cdbName)
+        tmqCom.startTmqSimProcess(self.pollDelay,self.paraDict["dbName"],self.showMsg, self.showRow,self.cdbName,0,0,self.paraDict["snapshot"])
 
         tdLog.info("After waiting for a commit notify, drop one stable")
         #time.sleep(3)