From 85ee1318d2f3138fba4ac0d9560a7d2ed97f990a Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Sat, 11 Mar 2023 17:44:35 +0800
Subject: [PATCH] refactor: add some logs.

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

diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c
index 14d056224a..a4f8b46395 100644
--- a/source/client/src/clientTmq.c
+++ b/source/client/src/clientTmq.c
@@ -460,6 +460,8 @@ static int32_t tmqCommitCb(void* param, SDataBuf* pBuf, int32_t code) {
 
     // update the offset value.
     pVg->committedOffset = pVg->currentOffset;
+    tscDebug("consumer:0x%" PRIx64 " subKey:%s vgId:%d, commit offset success. ordinal:%d/%d", pTmq->consumerId,
+             pParam->pOffset->subKey, pParam->vgId, index + 1, numOfVgroups);
   }
 
   taosThreadMutexUnlock(&pParam->pTmq->lock);
-- 
GitLab