From 5e832a1cc1441eaf8d64fe72c1a2af8829030d3d Mon Sep 17 00:00:00 2001
From: Kai Wang <kwang@apache.org>
Date: Sun, 29 Sep 2024 15:13:38 +0800
Subject: [PATCH] [fix][test] Fix ReplicatorRateLimiterTest (#23369)

---
 .../apache/pulsar/broker/service/ReplicatorRateLimiterTest.java | 2 +-
 1 file changed, 1 insertion(+), 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
index bec6b558ea401..2e0dd0a90e8a6 100644
--- 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);