diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SubscriptionMessageDispatchThrottlingTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SubscriptionMessageDispatchThrottlingTest.java index 7ed88f5c516f28..d18da29404cbd7 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SubscriptionMessageDispatchThrottlingTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/SubscriptionMessageDispatchThrottlingTest.java @@ -210,8 +210,8 @@ public void testMessageRateLimitingReceiveAllMessagesAfterThrottling(Subscriptio * verify rate-limiting should throttle message-dispatching based on byte-rate * *
-     *  1. dispatch-byte-rate = 100 bytes/sec
-     *  2. send 30 msgs : each with 10 byte
+     *  1. dispatch-byte-rate = 1000 bytes/sec
+     *  2. send 30 msgs : each with 100 byte
      *  3. it should take up to 2 second to receive all messages
      * 
* @@ -226,7 +226,7 @@ public void testBytesRateLimitingReceiveAllMessagesAfterThrottling(SubscriptionT final String topicName = "persistent://" + namespace + "/throttlingAll-" + System.nanoTime(); final String subName = "my-subscriber-name-" + subscription; - final int byteRate = 100; + final int byteRate = 1000; DispatchRate dispatchRate = new DispatchRate(-1, byteRate, 1); admin.namespaces().createNamespace(namespace, Sets.newHashSet("test")); admin.namespaces().setSubscriptionDispatchRate(namespace, dispatchRate);