This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from cc0247b MINOR: Leaves lock() outside the try block (#9687)
add 4f2f08e KAFKA-10792: Prevent source task shutdown from blocking
herder thread (#9669)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/runtime/WorkerSourceTask.java | 44 +-
.../connect/integration/BlockingConnectorTest.java | 566 +++++++++++++++++----
.../connect/runtime/ErrorHandlingTaskTest.java | 6 -
.../ErrorHandlingTaskWithTopicCreationTest.java | 6 -
4 files changed, 472 insertions(+), 150 deletions(-)
