From 0929be690dac0d29254bb3328fec7025f2531d2e Mon Sep 17 00:00:00 2001 From: wangmm0220 Date: Sun, 9 Jul 2023 11:54:53 +0800 Subject: [PATCH] fix:seek to offset - 1 --- source/client/src/clientTmq.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c index d9f021211c..53a534b83a 100644 --- a/source/client/src/clientTmq.c +++ b/source/client/src/clientTmq.c @@ -2794,7 +2794,7 @@ int32_t tmq_offset_seek(tmq_t* tmq, const char* pTopicName, int32_t vgId, int64_ // update the offset, and then commit to vnode if (pOffsetInfo->currentOffset.type == TMQ_OFFSET__LOG) { - pOffsetInfo->currentOffset.version = offset; + pOffsetInfo->currentOffset.version = offset - 1; pOffsetInfo->committedOffset.version = INT64_MIN; pVg->seekUpdated = true; }