From 9b70420b3c5efeb52d864ff0912b8af3a343e6e4 Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Wed, 8 Jun 2022 18:58:52 +0800 Subject: [PATCH] fix case issue --- tests/test/c/tmqSim.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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;