remove memory limit code

apache · Mar 28, 2022 · 2b03aef · 2b03aef
1 parent f70d880
commit 2b03aef
Showing 1 changed file with 1 addition and 3 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
@@ -1047,13 +1047,11 @@ protected boolean hasPendingBatchReceive() {
     }
 
     protected void resetIncomingMessageSize() {
-        long size = INCOMING_MESSAGES_SIZE_UPDATER.getAndSet(this, 0);
-        client.getMemoryLimitController().releaseMemory(size);
+        INCOMING_MESSAGES_SIZE_UPDATER.getAndSet(this, 0);
     }
 
     protected void decreaseIncomingMessageSize(final Message<?> message) {
         INCOMING_MESSAGES_SIZE_UPDATER.addAndGet(this, -message.size());
-        client.getMemoryLimitController().releaseMemory(message.size());
     }
 
     public long getIncomingMessageSize() {