This is an automated email from the ASF dual-hosted git repository. lhotari pushed a commit to branch branch-3.0 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 997158b9af126b09f9ff99faa58588ec2013b86f 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 fd18949a2e6..e0df107f73f 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 @@ -357,13 +357,13 @@ 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); Consumer<byte[]> consumer = pulsarClient.newConsumer().topic(topic).subscriptionName("subscriber-1") .subscribe(); Producer<byte[]> producer = pulsarClient.newProducer().topic(topic).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(() -> {
