Skip to content

Commit cc13d08

Browse files
committed
fix test
1 parent d948042 commit cc13d08

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

tests/ReaderTest.cc

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -229,7 +229,9 @@ TEST_P(ReaderTest, testReaderOnLastMessage) {
229229
initTopic(topicName);
230230

231231
Producer producer;
232-
ASSERT_EQ(ResultOk, client.createProducer(topicName, producer));
232+
ProducerConfiguration producerConf;
233+
producerConf.setPartitionsRoutingMode(ProducerConfiguration::UseSinglePartition);
234+
ASSERT_EQ(ResultOk, client.createProducer(topicName, producerConf, producer));
233235

234236
for (int i = 0; i < 10; i++) {
235237
std::string content = "my-message-" + std::to_string(i);

0 commit comments

Comments
 (0)