fix: getTotalBatchMaxBytes return holdSize

apache · Jun 3, 2024 · c3ee1c1 · c3ee1c1
1 parent 949991e
commit c3ee1c1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java b/client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java
@@ -184,7 +184,7 @@ void batchMaxBytes(long holdSize) {
     }
 
     long getTotalBatchMaxBytes() {
-        return holdSize;
+        return totalHoldSize;
     }
 
     void totalBatchMaxBytes(long totalHoldSize) {