From bca6912923bd629f3255d517d8905e3fd39082c1 Mon Sep 17 00:00:00 2001 From: Sergey J Date: Tue, 20 May 2025 19:00:53 +0300 Subject: patch for ydb cfg kafka port (#18561) --- ydb/tools/cfg/base.py | 1 + ydb/tools/cfg/static.py | 3 +++ 2 files changed, 4 insertions(+) diff --git a/ydb/tools/cfg/base.py b/ydb/tools/cfg/base.py index 818051df141..9a17285a20b 100644 --- a/ydb/tools/cfg/base.py +++ b/ydb/tools/cfg/base.py @@ -311,6 +311,7 @@ class ClusterDetailsProvider(object): self.blob_storage_config = self.__cluster_description.get("blob_storage_config") self.bootstrap_config = self.__cluster_description.get("bootstrap_config") self.memory_controller_config = self.__cluster_description.get("memory_controller_config") + self.kafka_proxy_config = self.__cluster_description.get("kafka_proxy_config") self.s3_proxy_resolver_config = self.__cluster_description.get("s3_proxy_resolver_config") self.channel_profile_config = self.__cluster_description.get("channel_profile_config") self.immediate_controls_config = self.__cluster_description.get("immediate_controls_config") diff --git a/ydb/tools/cfg/static.py b/ydb/tools/cfg/static.py index 407cff50766..4cc3ad674e2 100644 --- a/ydb/tools/cfg/static.py +++ b/ydb/tools/cfg/static.py @@ -514,6 +514,9 @@ class StaticConfigGenerator(object): if self.__cluster_details.memory_controller_config is not None: normalized_config["memory_controller_config"] = self.__cluster_details.memory_controller_config + if self.__cluster_details.kafka_proxy_config is not None: + normalized_config["kafka_proxy_config"] = self.__cluster_details.kafka_proxy_config + if self.__cluster_details.s3_proxy_resolver_config is not None: normalized_config["s3_proxy_resolver_config"] = self.__cluster_details.s3_proxy_resolver_config -- cgit v1.3