Merge b6dedaa into fb228ee

Author: rekby

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

@@ -359,6 +359,11 @@ 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
+        print(f"rekby-debug: kafka enabled, 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:
@@ -178,7 +179,6 @@ def __init__(
         self._pdisks_info = []
         if self.__grpc_ssl_enable:
             self.__grpc_tls_data_path = grpc_tls_data_path or yatest.common.output_path()
-            cert_pem, key_pem = tls_tools.generate_selfsigned_cert(_get_fqdn())
             self.__grpc_tls_ca = cert_pem
             self.__grpc_tls_key = key_pem
             self.__grpc_tls_cert = cert_pem
@@ -431,6 +431,14 @@ def __init__(
             self.yaml_config["feature_flags"]["enable_external_data_sources"] = True
             self.yaml_config["feature_flags"]["enable_script_execution_operations"] = True
 
+        print(f"rekby-debug: kafka port for config: {kafka_api_port}")
+        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