From 4b3015a32e22b3d857fb98b2a58e9714b56e0859 Mon Sep 17 00:00:00 2001 From: Nikita Saveliev Date: Thu, 29 Aug 2024 15:48:17 +0000 Subject: [PATCH] Fix pqv1 max partitions --- .../cpp/client/ydb_persqueue_public/impl/persqueue_impl.h | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/ydb/public/sdk/cpp/client/ydb_persqueue_public/impl/persqueue_impl.h b/ydb/public/sdk/cpp/client/ydb_persqueue_public/impl/persqueue_impl.h index 5786a7b52207..519c3df9ef5f 100644 --- a/ydb/public/sdk/cpp/client/ydb_persqueue_public/impl/persqueue_impl.h +++ b/ydb/public/sdk/cpp/client/ydb_persqueue_public/impl/persqueue_impl.h @@ -56,7 +56,7 @@ class TPersQueueClient::TImpl : public TClientImplCommonset_max_active_partitions(settings.PartitionsCount_); + props.mutable_auto_partitioning_settings()->set_max_active_partitions(*settings.MaxPartitionsCount_); autoPartitioningSettingsDefined = true; } if (settings.AutoPartitioningStrategy_.Defined()) { @@ -76,9 +76,7 @@ class TPersQueueClient::TImpl : public TClientImplCommonset_min_active_partitions(settings.PartitionsCount_); }