From 3896e148fdf522d87bd6ef655508453270eb0349 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Wed, 17 May 2023 11:37:38 +0800 Subject: [PATCH] log(tmq): add some logs. --- source/dnode/vnode/src/tq/tq.c | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index f6f2b3ec53..a0da2c1cbe 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -319,11 +319,15 @@ int32_t tqProcessSeekReq(STQ* pTq, int64_t sversion, char* msg, int32_t msgLen) SDecoder decoder; tDecoderInit(&decoder, (uint8_t*)msg, msgLen); if (tDecodeMqVgOffset(&decoder, &vgOffset) < 0) { + tqError("vgId:%d failed to decode seek msg", vgId); return -1; } tDecoderClear(&decoder); + tqDebug("topic:%s, vgId:%d process offset seek by consumer:0x%" PRIx64 ", req offset:%" PRId64, + vgOffset.offset.subKey, vgId, vgOffset.consumerId, vgOffset.offset.val.version); + STqOffset* pOffset = &vgOffset.offset; if (pOffset->val.type != TMQ_OFFSET__LOG) { tqError("vgId:%d, subKey:%s invalid seek offset type:%d", vgId, pOffset->subKey, pOffset->val.type); @@ -385,6 +389,9 @@ int32_t tqProcessSeekReq(STQ* pTq, int64_t sversion, char* msg, int32_t msgLen) return -1; } + tqDebug("topic:%s, vgId:%d consumer:0x%" PRIx64 " offset is update to:%" PRId64, vgOffset.offset.subKey, vgId, + vgOffset.consumerId, vgOffset.offset.val.version); + return 0; }