From ca7eee7451a3b92443a0e952b20035dea30a96d2 Mon Sep 17 00:00:00 2001
From: Liu Jicong <liujicong@qq.com>
Date: Fri, 8 Apr 2022 14:42:30 +0800
Subject: [PATCH] add log

---
 include/common/tmsg.h | 1 +
 tests/test/c/tmqSim.c | 6 ------
 2 files changed, 1 insertion(+), 6 deletions(-)

diff --git a/include/common/tmsg.h b/include/common/tmsg.h
index 61da9cb213..aeaf5832b9 100644
--- a/include/common/tmsg.h
+++ b/include/common/tmsg.h
@@ -2273,6 +2273,7 @@ typedef struct {
   char    cgroup[TSDB_CGROUP_LEN];
 
   int64_t currentOffset;
+  uint64_t reqId;
   char    topic[TSDB_TOPIC_FNAME_LEN];
 } SMqPollReq;
 
diff --git a/tests/test/c/tmqSim.c b/tests/test/c/tmqSim.c
index 22d8c2b735..7372745cb8 100644
--- a/tests/test/c/tmqSim.c
+++ b/tests/test/c/tmqSim.c
@@ -274,17 +274,11 @@ int main(int32_t argc, char *argv[]) {
   
   loop_consume(tmq);
 
-  err = tmq_unsubscribe(tmq);
-  ASSERT(err == TMQ_RESP_ERR__SUCCESS);
-
-
-  #if 0
   err = tmq_unsubscribe(tmq);
   if (err) {
     printf("tmq_unsubscribe() fail, reason: %s\n", tmq_err2str(err));
     exit(-1);
   }
-  #endif
 
   return 0;
 }