(pulsar) branch master updated: [fix][client] Fix double recycling of the message in isValidConsumerEpoch method (#25008)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new c8d6208bb36 [fix][client] Fix double recycling of the message in 
isValidConsumerEpoch method (#25008)
c8d6208bb36 is described below

commit c8d6208bb364c3c65215cf235feeaec20c0adb9d
Author: Lari Hotari <lhot...@users.noreply.github.com>
AuthorDate: Mon Nov 24 14:36:47 2025 +0200

    [fix][client] Fix double recycling of the message in isValidConsumerEpoch 
method (#25008)
---
 .../src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java        | 1 -
 1 file changed, 1 deletion(-)

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 c4b413055d4..f3f3a6bf116 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
@@ -1347,7 +1347,6 @@ public abstract class ConsumerBase<T> extends 
HandlerState implements Consumer<T
             log.info("Consumer filter old epoch message, topic : [{}], 
messageId : [{}], messageConsumerEpoch : [{}], "
                     + "consumerEpoch : [{}]", topic, message.getMessageId(), 
message.getConsumerEpoch(), consumerEpoch);
             message.release();
-            message.recycle();
             return false;
         }
         return true;