提交 574010e0 编写于 作者: wmmhello's avatar wmmhello

fix:set firset version to reqOffset of response

上级 7bc19df0
...@@ -2262,6 +2262,8 @@ int64_t tmq_get_vgroup_offset(TAOS_RES* res) { ...@@ -2262,6 +2262,8 @@ int64_t tmq_get_vgroup_offset(TAOS_RES* res) {
STqOffsetVal* pOffset = &pRspObj->rsp.reqOffset; STqOffsetVal* pOffset = &pRspObj->rsp.reqOffset;
if (pOffset->type == TMQ_OFFSET__LOG) { if (pOffset->type == TMQ_OFFSET__LOG) {
return pRspObj->rsp.reqOffset.version; return pRspObj->rsp.reqOffset.version;
}else{
tscError("invalid offset type:%d", pOffset->type);
} }
} else if (TD_RES_TMQ_META(res)) { } else if (TD_RES_TMQ_META(res)) {
SMqMetaRspObj* pRspObj = (SMqMetaRspObj*)res; SMqMetaRspObj* pRspObj = (SMqMetaRspObj*)res;
...@@ -2273,6 +2275,8 @@ int64_t tmq_get_vgroup_offset(TAOS_RES* res) { ...@@ -2273,6 +2275,8 @@ int64_t tmq_get_vgroup_offset(TAOS_RES* res) {
if (pRspObj->rsp.reqOffset.type == TMQ_OFFSET__LOG) { if (pRspObj->rsp.reqOffset.type == TMQ_OFFSET__LOG) {
return pRspObj->rsp.reqOffset.version; return pRspObj->rsp.reqOffset.version;
} }
} else{
tscError("invalid tmqtype:%d", *(int8_t*)res);
} }
// data from tsdb, no valid offset info // data from tsdb, no valid offset info
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册