Add missing SSL config to kafka admin clients

fkie-cad · Nov 21, 2024 · 5d35711 · 5d35711
1 parent 56cf412
commit 5d35711
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 0 deletions.
diff --git a/logprep/connector/confluent_kafka/input.py b/logprep/connector/confluent_kafka/input.py
@@ -288,6 +288,9 @@ def _admin(self) -> AdminClient:
             confluent_kafka admin client object
         """
         admin_config = {"bootstrap.servers": self._config.kafka_config["bootstrap.servers"]}
+        for key, value in self._config.kafka_config.items():
+            if key.startswith(("security.", "ssl.")):
+                admin_config[key] = value
         return AdminClient(admin_config)
 
     @cached_property

diff --git a/logprep/connector/confluent_kafka/output.py b/logprep/connector/confluent_kafka/output.py
@@ -212,6 +212,9 @@ def _admin(self) -> AdminClient:
             confluent_kafka admin client object
         """
         admin_config = {"bootstrap.servers": self._config.kafka_config["bootstrap.servers"]}
+        for key, value in self._config.kafka_config.items():
+            if key.startswith(("security.", "ssl.")):
+                admin_config[key] = value
         return AdminClient(admin_config)
 
     @cached_property