change PartitionsRoutingMode default from UseSinglePartition to RoundRobinDistribution

Author: fanjianye

lib/PartitionedProducerImpl.cc

@@ -65,17 +65,17 @@ PartitionedProducerImpl::PartitionedProducerImpl(ClientImplPtr client, const Top
 
 MessageRoutingPolicyPtr PartitionedProducerImpl::getMessageRouter() {
     switch (conf_.getPartitionsRoutingMode()) {
+        case ProducerConfiguration::UseSinglePartition:
+            return std::make_shared<SinglePartitionMessageRouter>(getNumPartitions(),
+                                                                  conf_.getHashingScheme());
+        case ProducerConfiguration::CustomPartition:
+            return conf_.getMessageRouterPtr();
         case ProducerConfiguration::RoundRobinDistribution:
+        default:
             return std::make_shared<RoundRobinMessageRouter>(
                 conf_.getHashingScheme(), conf_.getBatchingEnabled(), conf_.getBatchingMaxMessages(),
                 conf_.getBatchingMaxAllowedSizeInBytes(),
                 boost::posix_time::milliseconds(conf_.getBatchingMaxPublishDelayMs()));
-        case ProducerConfiguration::CustomPartition:
-            return conf_.getMessageRouterPtr();
-        case ProducerConfiguration::UseSinglePartition:
-        default:
-            return std::make_shared<SinglePartitionMessageRouter>(getNumPartitions(),
-                                                                  conf_.getHashingScheme());
     }
 }
 

lib/ProducerConfigurationImpl.h

@@ -34,7 +34,7 @@ struct ProducerConfigurationImpl {
     CompressionType compressionType{CompressionNone};
     int maxPendingMessages{1000};
     int maxPendingMessagesAcrossPartitions{50000};
-    ProducerConfiguration::PartitionsRoutingMode routingMode{ProducerConfiguration::UseSinglePartition};
+    ProducerConfiguration::PartitionsRoutingMode routingMode{ProducerConfiguration::RoundRobinDistribution};
     MessageRoutingPolicyPtr messageRouter;
     ProducerConfiguration::HashingScheme hashingScheme{ProducerConfiguration::BoostHash};
     bool useLazyStartPartitionedProducers{false};