Enable kafka api by env variable (#11892)

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 _is_env_option_enabled('YDB_KAFKA_API_ENABLED'):
+        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,
@@ -547,3 +551,12 @@ def start_recipe(args):
 def stop_recipe(args):
     arguments = produce_arguments(args)
     cleanup(arguments)
+
+
+def _is_true_string(s):
+    s = s.upper()
+    return s in ['1', 'TRUE', 'YES', 'ON']
+
+
+def _is_env_option_enabled(name):
+    return _is_true_string(os.environ.get(name, "FALSE"))

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