You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by kk...@apache.org on 2020/04/30 00:07:33 UTC

[kafka] branch trunk updated (dc4d439 -> 0ee19e8)

This is an automated email from the ASF dual-hosted git repository.

kkarantasis pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from dc4d439  KAFKA-9875: Make integration tests more resilient (#8578)
     add 0ee19e8  KAFKA-9830: Implement AutoCloseable in ErrorReporter and subclasses (#8442)

No new revisions were added by this update.

Summary of changes:
 .../kafka/connect/runtime/WorkerSinkTask.java      |  2 +
 .../kafka/connect/runtime/WorkerSourceTask.java    |  2 +
 .../runtime/errors/DeadLetterQueueReporter.java    |  5 ++
 .../connect/runtime/errors/ErrorReporter.java      |  4 +-
 .../connect/runtime/errors/ProcessingContext.java  | 18 ++++-
 .../runtime/errors/RetryWithToleranceOperator.java |  7 +-
 .../connect/runtime/ErrorHandlingTaskTest.java     | 89 ++++++++++++++++++++++
 .../connect/runtime/errors/ErrorReporterTest.java  | 14 ++++
 8 files changed, 138 insertions(+), 3 deletions(-)