From 61cff54a3ca0b29e83ca8180148a27e491360d46 Mon Sep 17 00:00:00 2001
From: Jiwe Guo <technoboy@apache.org>
Date: Wed, 16 Nov 2022 12:27:09 +0800
Subject: [PATCH] fix test.

---
 .../main/java/org/apache/pulsar/client/impl/ConsumerBase.java  | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
index f615171660e36..3a8bb1867c91b 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java
@@ -850,8 +850,7 @@ protected boolean enqueueMessageAndCheckBatchReceive(Message<T> message) {
         // synchronize redeliverUnacknowledgedMessages().
         incomingQueueLock.lock();
         try {
-            if (isValidConsumerEpoch((MessageImpl<T>) message) && canEnqueueMessage(message)
-                    && incomingMessages.offer(message)) {
+            if (canEnqueueMessage(message) && incomingMessages.offer(message)) {
                 // After we have enqueued the messages on `incomingMessages` queue, we cannot touch the message
                 // instance anymore, since for pooled messages, this instance was possibly already been released
                 // and recycled.