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 6abb913 KAFKA-9841: Revoke duplicate connectors and tasks when zombie workers return with an outdated assignment (#8453) add 775f0d4 KAFKA-9066: Retain metrics for failed tasks (#8502) No new revisions were added by this update. Summary of changes: .../org/apache/kafka/connect/runtime/Worker.java | 7 +++++- .../kafka/connect/runtime/WorkerSinkTask.java | 8 +++++-- .../kafka/connect/runtime/WorkerSourceTask.java | 8 +++++-- .../apache/kafka/connect/runtime/WorkerTask.java | 27 ++++++++-------------- .../kafka/connect/runtime/WorkerTaskTest.java | 9 -------- .../apache/kafka/connect/runtime/WorkerTest.java | 12 ++++++++++ .../runtime/WorkerWithTopicCreationTest.java | 12 ++++++++++ 7 files changed, 52 insertions(+), 31 deletions(-)