remove memory limit code

apache · Apr 1, 2022 · db678d9 · db678d9
1 parent 99e6099
commit db678d9
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
@@ -1048,13 +1048,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() {