You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by xy...@apache.org on 2025/10/17 02:31:51 UTC

(pulsar-client-cpp) 01/02: Fix flaky testHasMessageAvailableWhenCreated (#511)

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

xyz pushed a commit to branch branch-3.8
in repository https://gitbox.apache.org/repos/asf/pulsar-client-cpp.git

commit 340ca3c63a654dec800dde4f58d07bdbe84e2e62
Author: Yunze Xu <xy...@163.com>
AuthorDate: Thu Oct 16 23:19:24 2025 +0800

    Fix flaky testHasMessageAvailableWhenCreated (#511)
    
    (cherry picked from commit 2b84925b097d649091ca0160009cd5e3c1c50062)
---
 tests/ReaderTest.cc | 1 +
 1 file changed, 1 insertion(+)

diff --git a/tests/ReaderTest.cc b/tests/ReaderTest.cc
index 3da25e9..ba5b2a9 100644
--- a/tests/ReaderTest.cc
+++ b/tests/ReaderTest.cc
@@ -645,6 +645,7 @@ TEST_P(ReaderTest, testHasMessageAvailableWhenCreated) {
 
     ProducerConfiguration producerConf;
     producerConf.setBatchingMaxMessages(3);
+    producerConf.setPartitionsRoutingMode(ProducerConfiguration::UseSinglePartition);
     Producer producer;
     ASSERT_EQ(ResultOk, client.createProducer(topicName, producerConf, producer));