Skip to content

Commit bca6912

Browse files
authored
patch for ydb cfg kafka port (#18561)
1 parent a8ecf24 commit bca6912

File tree

2 files changed

+4
-0
lines changed

2 files changed

+4
-0
lines changed

ydb/tools/cfg/base.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -311,6 +311,7 @@ def __init__(self, template, host_info_provider, validator=None, database=None,
311311
self.blob_storage_config = self.__cluster_description.get("blob_storage_config")
312312
self.bootstrap_config = self.__cluster_description.get("bootstrap_config")
313313
self.memory_controller_config = self.__cluster_description.get("memory_controller_config")
314+
self.kafka_proxy_config = self.__cluster_description.get("kafka_proxy_config")
314315
self.s3_proxy_resolver_config = self.__cluster_description.get("s3_proxy_resolver_config")
315316
self.channel_profile_config = self.__cluster_description.get("channel_profile_config")
316317
self.immediate_controls_config = self.__cluster_description.get("immediate_controls_config")

ydb/tools/cfg/static.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -514,6 +514,9 @@ def get_normalized_config(self):
514514
if self.__cluster_details.memory_controller_config is not None:
515515
normalized_config["memory_controller_config"] = self.__cluster_details.memory_controller_config
516516

517+
if self.__cluster_details.kafka_proxy_config is not None:
518+
normalized_config["kafka_proxy_config"] = self.__cluster_details.kafka_proxy_config
519+
517520
if self.__cluster_details.s3_proxy_resolver_config is not None:
518521
normalized_config["s3_proxy_resolver_config"] = self.__cluster_details.s3_proxy_resolver_config
519522

0 commit comments

Comments
 (0)