Skip to content

debezium/dbz#1088 Add Azure Event Hubs connection validator#282

Open
JunWang222 wants to merge 1 commit into
debezium:mainfrom
JunWang222:dbz-1088-eventhubs-validator
Open

debezium/dbz#1088 Add Azure Event Hubs connection validator#282
JunWang222 wants to merge 1 commit into
debezium:mainfrom
JunWang222:dbz-1088-eventhubs-validator

Conversation

@JunWang222
Copy link
Copy Markdown

@JunWang222 JunWang222 commented Mar 4, 2026

debezium/dbz#1088 Add Azure Event Hubs connection validator

Changes
Implemented AzureEventHubsConnectionValidator that verifies a real connection to Event Hubs using the provided connection string and hub name
Wired it into the platform's validator factory and UI schema so it integrates with the existing connection validation flow

Tests
Added unit tests covering each error case (bad credentials, wrong hub, malformed string, missing fields)
Added integration tests running against the official Azure Event Hubs emulator via Testcontainers — no real Azure account needed

Closes debezium/dbz#1088

@JunWang222 JunWang222 force-pushed the dbz-1088-eventhubs-validator branch from 8040965 to 8f50bc9 Compare March 4, 2026 05:58
@jpechane
Copy link
Copy Markdown
Contributor

jpechane commented Mar 4, 2026

@JunWang222 Could you please run formatter plugin locall and re-format the source code?

@JunWang222 JunWang222 force-pushed the dbz-1088-eventhubs-validator branch from 8f50bc9 to 20060b2 Compare March 4, 2026 06:31
@JunWang222
Copy link
Copy Markdown
Author

Could you please run formatter plugin locall and re-format the source code?

Thank you for the feedback! I just noticed the CI job and run the formatter to format the code

@JunWang222 JunWang222 force-pushed the dbz-1088-eventhubs-validator branch from 20060b2 to 96c918e Compare March 4, 2026 06:41
Introduce Event Hubs connection validation in Conductor with schema and factory wiring, and add emulator-backed integration plus deterministic auth-path tests so connection checks are reliably covered.

Signed-off-by: JunWang222 <466529050@qq.com>
Copy link
Copy Markdown
Contributor

@jpechane jpechane left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

@JunWang222 LGTM, thanks!

@mfvitale If you've no comments feel free to merge yourself

@jpechane jpechane requested a review from mfvitale March 11, 2026 07:51
private String mapToValidatorName(String connectionType) {
return switch (connectionType) {
case "ORACLE", "MYSQL", "MARIADB", "SQLSERVER", "POSTGRESQL" -> "DATABASE";
case "AZURE_EVENTS_HUBS" -> "EVENTHUBS";
Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This is not necessary.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Add connection validator for Azure Event Hub [DBZ-9431]

3 participants