Skip to content

Commit 24211e3

Browse files
authored
Merge 4b3015a into 93089ee
2 parents 93089ee + 4b3015a commit 24211e3

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

ydb/public/sdk/cpp/client/ydb_persqueue_public/impl/persqueue_impl.h

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff 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

0 commit comments

Comments
 (0)