-
Notifications
You must be signed in to change notification settings - Fork 14.9k
KAFKA-13533: Clean up resources on failed connector and task startup #11608
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
@tombentley FYI, I've finished rebasing this. |
connect/runtime/src/main/java/org/apache/kafka/connect/util/Closeables.java
Outdated
Show resolved
Hide resolved
YeonCheolGit
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I don't have any authority but no additional opinion for this. 👍🏼
|
Downgrading to a draft until I can revisit and fix the merge conflicts. |
|
This PR is being marked as stale since it has not had any activity in 90 days. If you If you are having difficulty finding a reviewer, please reach out on the [mailing list](https://kafka.apache.org/contact). If this PR is no longer valid or desired, please feel free to close it. If no activity occurs in the next 30 days, it will be automatically closed. |
|
This PR has been closed since it has not had any activity in 120 days. If you feel like this |
Jira
Introduces and leverages a new
Closeablesutility class that can be used to track accruedAutoCloseableobjects via a try-with-resources block. Also switches theWorkerclass over to usePlugins::withClassLoaderwherever possible.Committer Checklist (excluded from commit message)