fix test.

apache · Nov 19, 2022 · 61cff54 · 61cff54
1 parent 6228045
commit 61cff54
Showing 1 changed file with 1 addition and 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
@@ -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.