Fix #18441: kafka connect password as secret value (#18742)

open-metadata · Nov 24, 2024 · 078424f · 078424f
1 parent b39e792
commit 078424f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/client.py b/ingestion/src/metadata/ingestion/source/pipeline/kafkaconnect/client.py
@@ -54,7 +54,7 @@ def __init__(self, config: KafkaConnectConnection):
         auth = None
         ssl_verify = config.verifySSL
         if config.KafkaConnectConfig:
-            auth = f"{config.KafkaConnectConfig.username}:{config.KafkaConnectConfig.password}"
+            auth = f"{config.KafkaConnectConfig.username}:{config.KafkaConnectConfig.password.get_secret_value()}"
         self.client = KafkaConnect(url=url, auth=auth, ssl_verify=ssl_verify)
 
     def get_cluster_info(self) -> Optional[dict]: