This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.1 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 38a67176d7a58d4bc8cbd9eb1aee98a3ae14b87d Author: Lari Hotari <[email protected]> AuthorDate: Mon Nov 24 14:36:47 2025 +0200 [fix][client] Fix double recycling of the message in isValidConsumerEpoch method (#25008) (cherry picked from commit c8d6208bb364c3c65215cf235feeaec20c0adb9d) --- .../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 f99860656ca..8066d849e5d 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 @@ -1338,7 +1338,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;
