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

Posted to commits@kafka.apache.org by ew...@apache.org on 2018/06/05 20:59:43 UTC

[kafka] branch trunk updated (ba0ebca -> faa15b8)

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

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


    from ba0ebca  [KAFKA-6730] Simplify State Store Recovery (#5013)
     add faa15b8  KAFKA-6981: Move the error handling configuration properties into the ConnectorConfig and SinkConnectorConfig classes (KIP-298)

No new revisions were added by this update.

Summary of changes:
 .../kafka/connect/runtime/ConnectorConfig.java     |  75 ++++++++++++++-
 .../kafka/connect/runtime/SinkConnectorConfig.java |  16 +++-
 .../org/apache/kafka/connect/runtime/Worker.java   |  20 ++--
 .../runtime/errors/DeadLetterQueueReporter.java    |  50 +++-------
 .../connect/runtime/errors/ErrorReporter.java      |   4 +-
 .../kafka/connect/runtime/errors/LogReporter.java  |  54 ++---------
 .../runtime/errors/RetryWithToleranceOperator.java | 106 +++++----------------
 .../connect/runtime/errors/ToleranceType.java      |   5 +-
 .../kafka/connect/runtime/AbstractHerderTest.java  |  25 ++---
 .../connect/runtime/ErrorHandlingTaskTest.java     |  67 +++++++------
 .../kafka/connect/runtime/WorkerSinkTaskTest.java  |   4 +-
 .../runtime/WorkerSinkTaskThreadedTest.java        |   6 +-
 .../connect/runtime/WorkerSourceTaskTest.java      |   4 +-
 .../kafka/connect/runtime/WorkerTaskTest.java      |   3 +-
 .../apache/kafka/connect/runtime/WorkerTest.java   |   7 +-
 .../connect/runtime/errors/ErrorReporterTest.java  |  46 +++++----
 .../errors/RetryWithToleranceOperatorTest.java     |  98 ++++++++++---------
 17 files changed, 284 insertions(+), 306 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
ewencp@apache.org.