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 0b201278142e3..d8defd79759dd 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():