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 ewe...@apache.org.