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 65320e799997b36be06268e680c0f1a85c18558f Author: Dream95 <[email protected]> AuthorDate: Mon Nov 10 20:10:11 2025 +0800 [fix][test] Fix invalid test NonPersistentTopicTest.testProducerRateLimit (#24957) Signed-off-by: Dream95 <[email protected]> (cherry picked from commit 0896c0a5fe23c57179faf8752b416bee5e43b6a2) --- .../java/org/apache/pulsar/client/api/NonPersistentTopicTest.java | 5 +++-- 1 file changed, 3 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 e0df107f73f..11b20c1f202 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 @@ -362,13 +362,14 @@ public class NonPersistentTopicTest extends ProducerConsumerBase { 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 = 500; CountDownLatch latch = new CountDownLatch(totalProduceMessages); for (int i = 0; i < totalProduceMessages; i++) { + final int messageIndex = i; executor.submit(() -> { try { - producer.send(msgData); + String message = "my-message-" + messageIndex; + producer.send(message.getBytes()); } catch (Exception e) { log.error("Failed to send message", e); failed.set(true);
