diff --git a/tests/test/c/tmqSim.c b/tests/test/c/tmqSim.c index eaca8f151e..5ea15a6622 100644 --- a/tests/test/c/tmqSim.c +++ b/tests/test/c/tmqSim.c @@ -354,6 +354,7 @@ void loop_consume(tmq_t* tmq) { if (0 != g_stConfInfo.showMsgFlag) { /*msg_process(tmqMsg);*/ } + /*tmq_commit(tmq, NULL, false);*/ tmq_message_destroy(tmqMsg); } else { break;