diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.java index c7a02aa812615..31130fafe9fa1 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/PrecisTopicPublishRateThrottleTest.java @@ -45,7 +45,7 @@ public void testPrecisTopicPublishRateLimitingDisabled() throws Exception { PublishRate publishRate = new PublishRate(1,10); // disable precis topic publish rate limiting conf.setPreciseTopicPublishRateLimiterEnable(false); - conf.setMaxPendingPublishdRequestsPerConnection(0); + conf.setMaxPendingPublishRequestsPerConnection(0); super.baseSetup(); final String topic = "persistent://prop/ns-abc/testPrecisTopicPublishRateLimiting"; org.apache.pulsar.client.api.Producer producer = pulsarClient.newProducer() @@ -84,7 +84,7 @@ public void testPrecisTopicPublishRateLimitingDisabled() throws Exception { public void testProducerBlockedByPrecisTopicPublishRateLimiting() throws Exception { PublishRate publishRate = new PublishRate(1,10); conf.setPreciseTopicPublishRateLimiterEnable(true); - conf.setMaxPendingPublishdRequestsPerConnection(0); + conf.setMaxPendingPublishRequestsPerConnection(0); super.baseSetup(); final String topic = "persistent://prop/ns-abc/testPrecisTopicPublishRateLimiting"; org.apache.pulsar.client.api.Producer producer = pulsarClient.newProducer() @@ -116,7 +116,7 @@ public void testProducerBlockedByPrecisTopicPublishRateLimiting() throws Excepti public void testPrecisTopicPublishRateLimitingProduceRefresh() throws Exception { PublishRate publishRate = new PublishRate(1,10); conf.setPreciseTopicPublishRateLimiterEnable(true); - conf.setMaxPendingPublishdRequestsPerConnection(0); + conf.setMaxPendingPublishRequestsPerConnection(0); super.baseSetup(); final String topic = "persistent://prop/ns-abc/testPrecisTopicPublishRateLimiting"; org.apache.pulsar.client.api.Producer producer = pulsarClient.newProducer()