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