Merge d498002 into afbc266

Author: rekby

ydb/public/tools/lib/cmds/__init__.py

@@ -359,6 +359,10 @@ def deploy(arguments):
     if 'YDB_EXPERIMENTAL_PG' in os.environ:
         optionals['pg_compatible_expirement'] = True
 
+    if os.environ.get('YDB_KAFKA_API_ENABLED', "0") == "1":
+        kafka_api_port = int(os.environ.get("YDB_KAFKA_PROXY_PORT", "9092"))
+        optionals['kafka_api_port'] = kafka_api_port
+
     configuration = KikimrConfigGenerator(
         erasure=parse_erasure(arguments),
         binary_paths=[arguments.ydb_binary_path] if arguments.ydb_binary_path else None,

ydb/tests/library/harness/kikimr_config.py

@@ -156,6 +156,7 @@ def __init__(
             default_user_sid=None,
             pg_compatible_expirement=False,
             generic_connector_config=None,  # typing.Optional[TGenericConnectorConfig]
+            kafka_api_port=None,
             metadata_section=None,
     ):
         if extra_feature_flags is None:
@@ -431,6 +432,13 @@ def __init__(
             self.yaml_config["feature_flags"]["enable_external_data_sources"] = True
             self.yaml_config["feature_flags"]["enable_script_execution_operations"] = True
 
+        if kafka_api_port is not None:
+            kafka_proxy_config = dict()
+            kafka_proxy_config["enable_kafka_proxy"] = True
+            kafka_proxy_config["listening_port"] = kafka_api_port
+
+            self.yaml_config["kafka_proxy_config"] = kafka_proxy_config
+
         self.full_config = dict()
         if metadata_section:
             self.full_config["metadata"] = metadata_section