Skip to content

Commit b378647

Browse files
authored
Fix pqv1 max partitions (#8485)
1 parent 3fbb785 commit b378647

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)