(pulsar) branch master updated: [fix][test] Fix flaky ReplicatorRateLimiterTest.testReplicatorRateLimiterMessageReceivedAllMessages (#25340)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new a1b1a9efecb [fix][test] Fix flaky 
ReplicatorRateLimiterTest.testReplicatorRateLimiterMessageReceivedAllMessages 
(#25340)
a1b1a9efecb is described below

commit a1b1a9efecbef0f1162c6dc6368341e32ff247e6
Author: Matteo Merli <mme...@apache.org>
AuthorDate: Thu Mar 19 02:06:18 2026 -0700

    [fix][test] Fix flaky 
ReplicatorRateLimiterTest.testReplicatorRateLimiterMessageReceivedAllMessages 
(#25340)
---
 .../apache/pulsar/broker/service/ReplicatorRateLimiterTest.java    | 7 ++++++-
 1 file changed, 6 insertions(+), 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 07546283e60..1384658982c 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
@@ -534,7 +534,12 @@ public class ReplicatorRateLimiterTest extends 
ReplicatorTestBase {
         Awaitility.await().pollDelay(1, TimeUnit.SECONDS).untilAsserted(() -> {
             log.info("Received message number: [{}]", totalReceived.get());
 
-            Assert.assertEquals(totalReceived.get(), messageRate);
+            // The rate limiter is not perfectly precise — allow +/- 20% 
tolerance.
+            int received = totalReceived.get();
+            Assert.assertTrue(received >= messageRate * 0.8,
+                    "Should receive at least 80% of " + messageRate + " 
messages, got " + received);
+            Assert.assertTrue(received <= messageRate * 1.2,
+                    "Should receive at most 120% of " + messageRate + " 
messages, got " + received);
         });
 
         consumer.close();