Skip to content

Commit 2b84925

Browse files
Fix flaky testHasMessageAvailableWhenCreated (apache#511)
1 parent 386dedc commit 2b84925

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

tests/ReaderTest.cc

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -645,6 +645,7 @@ TEST_P(ReaderTest, testHasMessageAvailableWhenCreated) {
645645

646646
ProducerConfiguration producerConf;
647647
producerConf.setBatchingMaxMessages(3);
648+
producerConf.setPartitionsRoutingMode(ProducerConfiguration::UseSinglePartition);
648649
Producer producer;
649650
ASSERT_EQ(ResultOk, client.createProducer(topicName, producerConf, producer));
650651

0 commit comments

Comments
 (0)