Skip to content

debezium/dbz#1097 Add support for connection validator for Milvus#310

Open
kartikangiras wants to merge 5 commits intodebezium:mainfrom
kartikangiras:dbz#1097
Open

debezium/dbz#1097 Add support for connection validator for Milvus#310
kartikangiras wants to merge 5 commits intodebezium:mainfrom
kartikangiras:dbz#1097

Conversation

@kartikangiras
Copy link
Copy Markdown

Description:

  • Implement ConnectionValidator for Milvus
  • Add MILVUS type to ConnectionEntity enum and JSON schema
  • Support token and username/password authentication
  • Include unit and integration tests with Testcontainers
  • Configure connection timeout (60s default)

fixes debezium/dbz#1097
DBZ-9440

@kartikangiras
Copy link
Copy Markdown
Author

@kmos @Naros PTAL into this PR Thanks.

@kmos kmos requested review from Naros, jpechane and kmos March 23, 2026 08:49
@mfvitale
Copy link
Copy Markdown
Member

Hi @kartikangiras Overall it LGMT. I just left a minor comment and started the CI

Copy link
Copy Markdown
Member

@Naros Naros left a comment

Choose a reason for hiding this comment

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

LGTM 🎉

@mfvitale
Copy link
Copy Markdown
Member

@kartikangiras failure seems related. Could you please take a look?

Signed-off-by: Kartik Angiras <angiraskartik@gmail.com>
…validation tests

Signed-off-by: Kartik Angiras <angiraskartik@gmail.com>
…s test common

Signed-off-by: Kartik Angiras <angiraskartik@gmail.com>
@kartikangiras
Copy link
Copy Markdown
Author

@mfvitale I have added certain test dependencies due to which CI check was failing.

@kartikangiras kartikangiras requested a review from mfvitale March 26, 2026 14:19
@kartikangiras
Copy link
Copy Markdown
Author

@mfvitale I have placed the MilvusTestResource under the test directory now.

Signed-off-by: Kartik Angiras <angiraskartik@gmail.com>
Comment on lines +174 to +175
if (errorMessage.contains("timeout") || errorMessage.contains("TimeoutException") ||
errorMessage.contains("deadline")) {
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.

@kmos @mfvitale, given that Milvus' error strategy is evolving and necessitates these string checks, should we consider encapsulating this in a dedicated Milvus package & handler that could return a Debezium-specific exception, so places like this can be much cleaner?

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.

I think, in general, that we should improve sink error management. So this could be something we could approach during DS rewrite?

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.

Yeah, I totally agree

@mfvitale
Copy link
Copy Markdown
Member

@kartikangiras Could you take a look to test failures?

@kartikangiras
Copy link
Copy Markdown
Author

@kartikangiras Could you take a look to test failures?

Yeah sure, I'm on it.

Signed-off-by: Kartik Angiras <angiraskartik@gmail.com>
@kartikangiras
Copy link
Copy Markdown
Author

kartikangiras commented Apr 2, 2026

@mfvitale I have resolved all the comments and made relevant changes Thanks.

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 Milvus [DBZ-9440]

5 participants