This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 27b2eda065e00da851bfbe54399067651888c392 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 af97634d08f..40c578865de 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 @@ -1319,7 +1319,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;
