Skip to content

Commit 91dddb5

Browse files
author
fanjianye
committed
modify the configuration test
1 parent a9419c3 commit 91dddb5

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

tests/ProducerConfigurationTest.cc

+4-1
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ TEST(ProducerConfigurationTest, testDefaultConfig) {
3333
ASSERT_EQ(conf.getCompressionType(), CompressionType::CompressionNone);
3434
ASSERT_EQ(conf.getMaxPendingMessages(), 1000);
3535
ASSERT_EQ(conf.getMaxPendingMessagesAcrossPartitions(), 50000);
36-
ASSERT_EQ(conf.getPartitionsRoutingMode(), ProducerConfiguration::UseSinglePartition);
36+
ASSERT_EQ(conf.getPartitionsRoutingMode(), ProducerConfiguration::RoundRobinDistribution);
3737
ASSERT_EQ(conf.getMessageRouterPtr(), MessageRoutingPolicyPtr{});
3838
ASSERT_EQ(conf.getHashingScheme(), ProducerConfiguration::BoostHash);
3939
ASSERT_EQ(conf.getBlockIfQueueFull(), false);
@@ -88,6 +88,9 @@ TEST(ProducerConfigurationTest, testCustomConfig) {
8888
conf.setMaxPendingMessagesAcrossPartitions(100000);
8989
ASSERT_EQ(conf.getMaxPendingMessagesAcrossPartitions(), 100000);
9090

91+
conf.setPartitionsRoutingMode(ProducerConfiguration::UseSinglePartition);
92+
ASSERT_EQ(conf.getPartitionsRoutingMode(), ProducerConfiguration::UseSinglePartition);
93+
9194
conf.setPartitionsRoutingMode(ProducerConfiguration::RoundRobinDistribution);
9295
ASSERT_EQ(conf.getPartitionsRoutingMode(), ProducerConfiguration::RoundRobinDistribution);
9396

0 commit comments

Comments
 (0)