fix:add interface tmq_get_connect to get TAOS from tmq

This commit is contained in:
wangmm0220 2023-09-22 11:44:37 +08:00
parent 06afd0bd33
commit 63a6aacc18
1 changed files with 0 additions and 1 deletions

View File

@ -3109,7 +3109,6 @@ int32_t tmq_offset_seek(tmq_t* tmq, const char* pTopicName, int32_t vgId, int64_
TAOS *tmq_get_connect(tmq_t *tmq){
if (tmq && tmq->pTscObj) {
int64_t *rid = taosMemoryCalloc(1, sizeof(int64_t));
return (TAOS *)(&(tmq->pTscObj->id));
}
return NULL;