diff --git a/tests/system-test/7-tmq/tmq_offset.py b/tests/system-test/7-tmq/tmq_offset.py
index 07d1a4bc04..7eabb50be2 100644
--- a/tests/system-test/7-tmq/tmq_offset.py
+++ b/tests/system-test/7-tmq/tmq_offset.py
@@ -45,6 +45,11 @@ class TDTestCase:
                 tdLog.exit("tmq_offset_test error!")
         else:
             buildPath = tdCom.getBuildPath()
+            cmdStr0 = '%s/build/bin/tmq_offset_test 5679'%(buildPath)
+            tdLog.info(cmdStr0)
+            if os.system(cmdStr0) != 0:
+                tdLog.exit(cmdStr0)
+
             cmdStr1 = '%s/build/bin/taosBenchmark -i 50 -B 1 -t 1000 -n 100000 -y &'%(buildPath)
             tdLog.info(cmdStr1)
             os.system(cmdStr1)
diff --git a/utils/test/c/tmq_offset_test.c b/utils/test/c/tmq_offset_test.c
index 43b5af19dc..25f048bab2 100644
--- a/utils/test/c/tmq_offset_test.c
+++ b/utils/test/c/tmq_offset_test.c
@@ -144,6 +144,7 @@ void test_ts5679(TAOS* pConn){
 
   for(int i = 0; i < numOfAssign; i++){
     int64_t committed = tmq_committed(tmq, "t_5679", pAssign[i].vgId);
+    printf("committed offset:%"PRId64"\n", committed);
     ASSERT(committed == TSDB_CODE_TMQ_NO_COMMITTED);
   }
 
@@ -374,9 +375,13 @@ void test_ts3756(TAOS* pConn){
 
 int main(int argc, char* argv[]) {
   TAOS* pConn = taos_connect("localhost", "root", "taosdata", NULL, 0);
-  test_offset(pConn);
-  test_ts3756(pConn);
-  test_ts5679(pConn);
+  if (argc == 2) {
+    test_ts5679(pConn);
+  }else{
+    test_offset(pConn);
+    test_ts3756(pConn);
+  }
+
   taos_close(pConn);
   return 0;
 }