feat (ingest): kafka-connect: adding Auth to Kafka Connect API (#4298)

metadata-ingestion/src/datahub/ingestion/source/kafka_connect.py

@@ -725,6 +725,12 @@ def __init__(self, config: KafkaConnectSourceConfig, ctx: PipelineContext):
         )
 
         # Test the connection
+        if self.config.username is not None and self.config.password is not None:
+            logger.info(
+                f"Connecting to {self.config.connect_uri} with Authentication..."
+            )
+            self.session.auth = (self.config.username, self.config.password)
+
         test_response = self.session.get(f"{self.config.connect_uri}")
         test_response.raise_for_status()
         logger.info(f"Connection to {self.config.connect_uri} is ok")