From 5c5e76f894cdb445968b568e136385d4d304b805 Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Mon, 12 Jun 2023 11:17:32 +0800
Subject: [PATCH] fix:modify offset description to string

---
 source/client/src/clientTmq.c | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c
index a989f06d84..a4d7760a7d 100644
--- a/source/client/src/clientTmq.c
+++ b/source/client/src/clientTmq.c
@@ -985,6 +985,14 @@ int32_t tmq_subscription(tmq_t* tmq, tmq_list_t** topics) {
 }
 
 int32_t tmq_unsubscribe(tmq_t* tmq) {
+  if (tmq->autoCommit) {
+    int32_t rsp = tmq_commit_sync(tmq, NULL);
+    if (rsp != 0) {
+      return rsp;
+    }
+  }
+  taosSsleep(2);  // sleep 2s for hb to send offset and rows to server
+
   int32_t     rsp;
   int32_t     retryCnt = 0;
   tmq_list_t* lst = tmq_list_new();