diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c
index cb38996ea13c9d88f2ce1fffa039c65f3d06ff2d..a989f06d847f76916a24c78be56b3967196643ee 100644
--- a/source/client/src/clientTmq.c
+++ b/source/client/src/clientTmq.c
@@ -2139,6 +2139,7 @@ int32_t tmq_consumer_close(tmq_t* tmq) {
         return rsp;
       }
     }
+    taosSsleep(2);  // sleep 2s for hb to send offset and rows to server
 
     int32_t     retryCnt = 0;
     tmq_list_t* lst = tmq_list_new();