Fix: msg rate acquire permit for msg/bytes (#716)

a64d7952 · Rajan Dhabalia · Matteo Merli · 21a618a1 · a64d7952
隐藏空白更改
内联并排

Showing with 2 addition and 2 deletion

pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java ...ice/persistent/PersistentDispatcherMultipleConsumers.java +2 -2

未找到文件。
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/persistent/PersistentDispatcherMultipleConsumers.java
@@ -354,8 +354,8 @@ public class PersistentDispatcherMultipleConsumers  extends AbstractDispatcherMu
                start += messagesForC;
                entriesToDispatch -= messagesForC;
                totalAvailablePermits -= msgSent;
-                totalMessagesSent += sentMsgInfo.getTotalSentMessageBytes();
-                totalBytesSent += sentMsgInfo.getTotalSentMessages();
+                totalMessagesSent += sentMsgInfo.getTotalSentMessages();
+                totalBytesSent += sentMsgInfo.getTotalSentMessageBytes();
            }
        }