diff --git a/tests/ReaderTest.cc b/tests/ReaderTest.cc index 3da25e9b..ba5b2a9f 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));