Skip to content

MINOR: Add integration test for plugin aliases - #16621

Merged
C0urante merged 3 commits into
apache:trunkfrom
C0urante:connect-plugin-aliases-integration-test
Jul 19, 2024
Merged

MINOR: Add integration test for plugin aliases#16621
C0urante merged 3 commits into
apache:trunkfrom
C0urante:connect-plugin-aliases-integration-test

Conversation

@C0urante

@C0urante C0urante commented Jul 18, 2024

Copy link
Copy Markdown
Contributor

Follow-up to #16608, discussed here and here.

Committer Checklist (excluded from commit message)

  • Verify design and implementation
  • Verify test coverage and CI build status
  • Verify documentation (including upgrade notes)

@C0urante C0urante added connect tests Test fixes (including flaky tests) labels Jul 18, 2024

@chia7712 chia7712 left a comment

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.

@C0urante thanks for this nice test.

sinkConnectorConfig.put(TOPICS_CONFIG, topic);
// Create the connector and ensure it and its tasks can start
connect.configureConnector(sinkConnectorName, sinkConnectorConfig);
connect.assertions().assertConnectorAndExactlyNumTasksAreRunning(sourceConnectorName, NUM_TASKS, "Connector and tasks did not start in time");

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.

It should be sinkConnectorName, right?

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

🤦 Thanks for the catch! Fixed in the latest commit. I also deleted each connector after they were no longer necessary, just to prevent typos like this from slipping in in the future.

@chia7712 chia7712 left a comment

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.

LGTM. one tiny comment is left but it is too tiny to block this PR

connect.start();

// Create a topic; not strictly necessary but prevents log spam when we start a source connector later
final String topic = "kafka17510";

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 guess the correct jira number is "17150"

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

Your eye for detail never ceases to impress me 😄
Fixed in the latest commit.

@C0urante

Copy link
Copy Markdown
Contributor Author

The changes in the latest commit are trivial, the build passes locally, and CI indicates that the prior commit is healthy. Merging...

@C0urante
C0urante merged commit 208bb1f into apache:trunk Jul 19, 2024
@C0urante
C0urante deleted the connect-plugin-aliases-integration-test branch July 19, 2024 16:47
abhi-ksolves pushed a commit to ksolves/kafka that referenced this pull request Jul 31, 2024
Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

connect tests Test fixes (including flaky tests)

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants