From 7a58f448a5011200a9b9e43305a522882445695f Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Thu, 6 Apr 2023 19:16:31 +0800
Subject: [PATCH] fix:time_wait in doAskEp

---
 source/client/src/clientTmq.c | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/source/client/src/clientTmq.c b/source/client/src/clientTmq.c
index 0e0cfaa94d..befcb00ac7 100644
--- a/source/client/src/clientTmq.c
+++ b/source/client/src/clientTmq.c
@@ -1426,6 +1426,9 @@ static bool doUpdateLocalEp(tmq_t* tmq, int32_t epoch, const SMqAskEpRsp* pRsp)
   char vgKey[TSDB_TOPIC_FNAME_LEN + 22];
   tscDebug("consumer:0x%" PRIx64 " update ep epoch from %d to epoch %d, incoming topics:%d, existed topics:%d",
            tmq->consumerId, tmq->epoch, epoch, topicNumGet, topicNumCur);
+  if (epoch <= tmq->epoch) {
+    return false;
+  }
 
   SArray* newTopics = taosArrayInit(topicNumGet, sizeof(SMqClientTopic));
   if (newTopics == NULL) {