|
@@ -304,8 +304,7 @@ namespace {
|
|
|
|
|
|
config.Opts->AddLongOption("auto-partitioning-max-partitions-count", "Maximum number of partitions for topic")
|
|
config.Opts->AddLongOption("auto-partitioning-max-partitions-count", "Maximum number of partitions for topic")
|
|
.Optional()
|
|
.Optional()
|
|
- .StoreResult(&MaxActivePartitions_)
|
|
|
|
- .DefaultValue(1);
|
|
|
|
|
|
+ .StoreResult(&MaxActivePartitions_);
|
|
AddAutoPartitioning(config, false);
|
|
AddAutoPartitioning(config, false);
|
|
}
|
|
}
|
|
|
|
|
|
@@ -329,7 +328,11 @@ namespace {
|
|
GetAutoPartitioningUpUtilizationPercent() ? *GetAutoPartitioningUpUtilizationPercent() : 0,
|
|
GetAutoPartitioningUpUtilizationPercent() ? *GetAutoPartitioningUpUtilizationPercent() : 0,
|
|
GetAutoPartitioninDownUtilizationPercent() ? *GetAutoPartitioninDownUtilizationPercent() : 0);
|
|
GetAutoPartitioninDownUtilizationPercent() ? *GetAutoPartitioninDownUtilizationPercent() : 0);
|
|
|
|
|
|
- settings.PartitioningSettings(MinActivePartitions_, MaxActivePartitions_, autoscaleSettings);
|
|
|
|
|
|
+ ui32 finalMaxActivePartitions = MaxActivePartitions_.Defined() ? *MaxActivePartitions_
|
|
|
|
+ : autoscaleSettings.GetStrategy() != NTopic::EAutoPartitioningStrategy::Disabled ? MinActivePartitions_ + 50
|
|
|
|
+ : MinActivePartitions_;
|
|
|
|
+
|
|
|
|
+ settings.PartitioningSettings(MinActivePartitions_, finalMaxActivePartitions, autoscaleSettings);
|
|
settings.PartitionWriteBurstBytes(PartitionWriteSpeedKbps_ * 1_KB);
|
|
settings.PartitionWriteBurstBytes(PartitionWriteSpeedKbps_ * 1_KB);
|
|
settings.PartitionWriteSpeedBytesPerSecond(PartitionWriteSpeedKbps_ * 1_KB);
|
|
settings.PartitionWriteSpeedBytesPerSecond(PartitionWriteSpeedKbps_ * 1_KB);
|
|
|
|
|