diff --git a/tests/test/c/tmqSim.c b/tests/test/c/tmqSim.c
index d0b582f375..e4ad4a466c 100644
--- a/tests/test/c/tmqSim.c
+++ b/tests/test/c/tmqSim.c
@@ -515,13 +515,13 @@ void* consumeThreadFunc(void* param) {
   if (err) {
     pError("tmq_unsubscribe() fail, reason: %s\n", tmq_err2str(err));
     pInfo->consumeMsgCnt = -1;
-    return NULL;
+    //return NULL;
   }
 
   err = tmq_consumer_close(pInfo->tmq);
   if (err) {
     pError("tmq_consumer_close() fail, reason: %s\n", tmq_err2str(err));
-    exit(-1);
+    //exit(-1);
   }
   pInfo->tmq = NULL;