This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-4.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit d4f02691fa76ee62531631dc6322317501e36e05 Author: Philipp Dolif <[email protected]> AuthorDate: Thu Nov 6 10:27:25 2025 +0100 [fix][test] Fix flaky NonPersistentTopicTest.testProducerRateLimit (#24951) (cherry picked from commit 7c343d0209a623bd75fbf0265a261fd2e70d20c1) --- .../java/org/apache/pulsar/client/api/NonPersistentTopicTest.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonPersistentTopicTest.java b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonPersistentTopicTest.java index aa34b619d11..6a9fb4b3484 100644 --- a/pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonPersistentTopicTest.java +++ b/pulsar-broker/src/test/java/org/apache/pulsar/client/api/NonPersistentTopicTest.java @@ -372,7 +372,7 @@ public class NonPersistentTopicTest extends ProducerConsumerBase { startBroker(); // produce message concurrently @Cleanup("shutdownNow") - ExecutorService executor = Executors.newFixedThreadPool(5); + ExecutorService executor = Executors.newFixedThreadPool(10); AtomicBoolean failed = new AtomicBoolean(false); @Cleanup Consumer<byte[]> consumer = pulsarClient.newConsumer().topic(topic).subscriptionName("subscriber-1") @@ -381,7 +381,7 @@ public class NonPersistentTopicTest extends ProducerConsumerBase { @Cleanup Producer<byte[]> producer = pulsarClient.newProducer().topic(topic).producerName(producerName).create(); byte[] msgData = "testData".getBytes(); - final int totalProduceMessages = 10; + final int totalProduceMessages = 500; CountDownLatch latch = new CountDownLatch(totalProduceMessages); for (int i = 0; i < totalProduceMessages; i++) { executor.submit(() -> {
