From 86cd304e1a1f785e739c49031cc07d2e83ecb665 Mon Sep 17 00:00:00 2001 From: Mayuri N Date: Tue, 10 Dec 2024 20:21:43 +0530 Subject: [PATCH] fix(ingest/kafka-connect): update connection test url When using confluent cloud, GET does work on root but works on /connectors endpoint --- .../src/datahub/ingestion/source/kafka/kafka_connect.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/metadata-ingestion/src/datahub/ingestion/source/kafka/kafka_connect.py b/metadata-ingestion/src/datahub/ingestion/source/kafka/kafka_connect.py index 0b201278142e3a..d8defd79759dd8 100644 --- a/metadata-ingestion/src/datahub/ingestion/source/kafka/kafka_connect.py +++ b/metadata-ingestion/src/datahub/ingestion/source/kafka/kafka_connect.py @@ -1155,7 +1155,7 @@ def __init__(self, config: KafkaConnectSourceConfig, ctx: PipelineContext): ) self.session.auth = (self.config.username, self.config.password) - test_response = self.session.get(f"{self.config.connect_uri}") + test_response = self.session.get(f"{self.config.connect_uri}/connectors") test_response.raise_for_status() logger.info(f"Connection to {self.config.connect_uri} is ok") if not jpype.isJVMStarted():