Skip to content

Commit

Permalink
fix(ingest/kafka-connect): update connection test url
Browse files Browse the repository at this point in the history
When using confluent cloud, GET does work on root but works on
/connectors endpoint
  • Loading branch information
mayurinehate committed Dec 11, 2024
1 parent 0a2ac70 commit 86cd304
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -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():
Expand Down

0 comments on commit 86cd304

Please sign in to comment.