You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by rh...@apache.org on 2020/06/11 03:04:03 UTC

[kafka] branch trunk updated (6abb913 -> 775f0d4)

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(-)