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

fix:tmq close error because of same committed offset

This commit is contained in:
wangmm0220 2023-09-06 10:15:41 +08:00
parent 0e9adcd573
commit 897fd5b8b5
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -982,7 +982,7 @@ int32_t tmq_unsubscribe(tmq_t* tmq) {
}
if (tmq->autoCommit) {
int32_t rsp = tmq_commit_sync(tmq, NULL);
if (rsp != 0) {
if (rsp != 0 && rsp != TSDB_CODE_TMQ_SAME_COMMITTED_VALUE) {
return rsp;
}
}
@ -2122,7 +2122,7 @@ int32_t tmq_consumer_close(tmq_t* tmq) {
// if auto commit is set, commit before close consumer. Otherwise, do nothing.
if (tmq->autoCommit) {
int32_t rsp = tmq_commit_sync(tmq, NULL);
if (rsp != 0) {
if (rsp != 0 && rsp != TSDB_CODE_TMQ_SAME_COMMITTED_VALUE) {
return rsp;
}
}