fix:[TS-5776]add raw type from consumer

This commit is contained in:
wangmm0220 2025-02-10 15:22:27 +08:00
parent 94b74cc20f
commit 170d78b69f
3 changed files with 197 additions and 111 deletions

View File

@ -1649,11 +1649,6 @@ void tmqMgmtClose(void) {
break;
}
atomic_store_8(&tmq->status, TMQ_CONSUMER_STATUS__CLOSED);
if (taosRemoveRef(tmqMgmt.rsetId, tmq->refId) != 0) {
qWarn("taosRemoveRef tmq refId:%" PRId64 " failed, error:%s", refId, tstrerror(terrno));
}
tmq = taosIterateRef(tmqMgmt.rsetId, refId);
}
taosCloseRef(tmqMgmt.rsetId);

File diff suppressed because one or more lines are too long

File diff suppressed because one or more lines are too long