Skip to content

Commit c8d6208

Browse files
authored
[fix][client] Fix double recycling of the message in isValidConsumerEpoch method (#25008)
1 parent 9deee37 commit c8d6208

File tree

1 file changed

+0
-1
lines changed

1 file changed

+0
-1
lines changed

pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerBase.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1347,7 +1347,6 @@ protected boolean isValidConsumerEpoch(MessageImpl<T> message) {
13471347
log.info("Consumer filter old epoch message, topic : [{}], messageId : [{}], messageConsumerEpoch : [{}], "
13481348
+ "consumerEpoch : [{}]", topic, message.getMessageId(), message.getConsumerEpoch(), consumerEpoch);
13491349
message.release();
1350-
message.recycle();
13511350
return false;
13521351
}
13531352
return true;

0 commit comments

Comments
 (0)