[fix][test] Fix ReplicatorRateLimiterTest (#23369)

apache · Sep 29, 2024 · 5e832a1 · 5e832a1
1 parent 950309b
commit 5e832a1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRateLimiterTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/broker/service/ReplicatorRateLimiterTest.java
@@ -611,7 +611,7 @@ public void testReplicatorRateLimiterByBytes() throws Exception {
     }
 
     private static Optional<DispatchRateLimiter> getRateLimiter(PersistentTopic topic) {
-        return getRateLimiter(topic);
+        return topic.getReplicators().values().stream().findFirst().map(Replicator::getRateLimiter).orElseThrow();
     }
 
     private static final Logger log = LoggerFactory.getLogger(ReplicatorRateLimiterTest.class);