Skip to content

Kafka Connect: Add end-to-end test for commit failure propagation#16432

Open
yadavay-amzn wants to merge 1 commit into
apache:mainfrom
yadavay-amzn:fix/16380-e2e-commit-failure-test
Open

Kafka Connect: Add end-to-end test for commit failure propagation#16432
yadavay-amzn wants to merge 1 commit into
apache:mainfrom
yadavay-amzn:fix/16380-e2e-commit-failure-test

Conversation

@yadavay-amzn
Copy link
Copy Markdown
Contributor

Fixes #16380.

Adds an end-to-end test verifying the full production path when a commit fails:

  1. Coordinator.process() throws RuntimeException
  2. CoordinatorThread.run() catches it, sets terminated=true
  3. CommitterImpl.save() calls processControlEvents(), detects termination
  4. NotRunningException is thrown, transitioning the task to FAILED

This complements the existing unit tests in TestCoordinator which call coordinator.process() directly (skipping CoordinatorThread).

Willingness to contribute

  • I can contribute this fix independently

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

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Kafka Connect: Add end-to-end test for commit failure propagation through CoordinatorThread

1 participant