File tree Expand file tree Collapse file tree 1 file changed +2
-4
lines changed
ydb/public/sdk/cpp/client/ydb_persqueue_public/impl Expand file tree Collapse file tree 1 file changed +2
-4
lines changed Original file line number Diff line number Diff line change @@ -56,7 +56,7 @@ class TPersQueueClient::TImpl : public TClientImplCommon<TPersQueueClient::TImpl
5656
5757 bool autoPartitioningSettingsDefined = false ;
5858 if (settings.MaxPartitionsCount_ .Defined ()) {
59- props.mutable_auto_partitioning_settings ()->set_max_active_partitions (settings.PartitionsCount_ );
59+ props.mutable_auto_partitioning_settings ()->set_max_active_partitions (* settings.MaxPartitionsCount_ );
6060 autoPartitioningSettingsDefined = true ;
6161 }
6262 if (settings.AutoPartitioningStrategy_ .Defined ()) {
@@ -76,9 +76,7 @@ class TPersQueueClient::TImpl : public TClientImplCommon<TPersQueueClient::TImpl
7676 autoPartitioningSettingsDefined = true ;
7777 }
7878
79- if (!autoPartitioningSettingsDefined) {
80- props.set_partitions_count (settings.PartitionsCount_ );
81- } else {
79+ if (autoPartitioningSettingsDefined) {
8280 props.mutable_auto_partitioning_settings ()->set_min_active_partitions (settings.PartitionsCount_ );
8381 }
8482
You can’t perform that action at this time.
0 commit comments