xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #22003 from taosdata/mark/tmq 

fix:seek failed in initilized status
This commit is contained in:
Haojun Liao 2023-07-10 09:08:14 +08:00 committed by GitHub
parent 2012a15dbf 8904f3857b
commit 0ec69ec3fe
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
source/client/src/clientTmq.c
View File

@ -2794,11 +2794,12 @@ int32_t tmq_offset_seek(tmq_t* tmq, const char* pTopicName, int32_t vgId, int64_
} }
// update the offset, and then commit to vnode // update the offset, and then commit to vnode
if (pOffsetInfo->currentOffset.type == TMQ_OFFSET__LOG) { // if (pOffsetInfo->currentOffset.type == TMQ_OFFSET__LOG) {
pOffsetInfo->currentOffset.version = offset; pOffsetInfo->currentOffset.type = TMQ_OFFSET__LOG;
pOffsetInfo->committedOffset.version = INT64_MIN; pOffsetInfo->currentOffset.version = offset >= 1 ? offset - 1 : 0;
pVg->seekUpdated = true; pOffsetInfo->committedOffset.version = INT64_MIN;
} pVg->seekUpdated = true;
// }
SMqRspObj rspObj = {.resType = RES_TYPE__TMQ, .vgId = pVg->vgId}; SMqRspObj rspObj = {.resType = RES_TYPE__TMQ, .vgId = pVg->vgId};
tstrncpy(rspObj.topic, tname, tListLen(rspObj.topic)); tstrncpy(rspObj.topic, tname, tListLen(rspObj.topic));