diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index 14d056224a9cfb78310a736d3e1388e9fa5c1939..a4f8b4639591a472556bbd5473baa3ad6e9f6f44 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);