Merge pull request #25503 from taosdata/fix/TS-4718

fix:[TS-4718]pMsg->data is null
taosdata · Apr 29, 2024 · 511e0de · 511e0de
2 parents 0b4f515 + 07291a7
commit 511e0de
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c
@@ -1356,6 +1356,11 @@ int32_t tmqPollCb(void* param, SDataBuf* pMsg, int32_t code) {
     goto END;
   }
 
+  if(pMsg->pData == NULL){
+    tscError("consumer:0x%" PRIx64 " msg discard from vgId:%d, since msg is NULL", tmq->consumerId, vgId);
+    goto FAIL;
+  }
+
   int32_t msgEpoch = ((SMqRspHead*)pMsg->pData)->epoch;
   int32_t clientEpoch = atomic_load_32(&tmq->epoch);
   if (msgEpoch < clientEpoch) {