From d7a4817124bf522cda05f0eb837561dd0db03414 Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Thu, 8 Jun 2023 19:11:15 +0800
Subject: [PATCH] feat:add parameters for consumer & add offset rows for
 subscription

---
 source/dnode/mnode/impl/src/mndConsumer.c | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/source/dnode/mnode/impl/src/mndConsumer.c b/source/dnode/mnode/impl/src/mndConsumer.c
index 6e54e8c1b7..4a6a37395d 100644
--- a/source/dnode/mnode/impl/src/mndConsumer.c
+++ b/source/dnode/mnode/impl/src/mndConsumer.c
@@ -433,8 +433,10 @@ static int32_t mndProcessMqHbReq(SRpcMsg *pMsg) {
     SMqSubscribeObj *pSub = mndAcquireSubscribe(pMnode, pConsumer->cgroup, data->topicName);
     taosRLockLatch(&pSub->lock);
     SMqConsumerEp *pConsumerEp = taosHashGet(pSub->consumerHash, &consumerId, sizeof(int64_t));
-    pConsumerEp->offsetRows = data->offsetRows;
-    data->offsetRows = NULL;
+    if(pConsumerEp){
+      pConsumerEp->offsetRows = data->offsetRows;
+      data->offsetRows = NULL;
+    }
     taosRUnLockLatch(&pSub->lock);
 
     mndReleaseSubscribe(pMnode, pSub);