This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch 2.6
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 177524c KAFKA-9441: remove prepareClose() to simplify task management
(#8833)
add 067488e KAFKA-9985: Sink connector may exhaust broker when writing in
DLQ (#8663)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/runtime/SinkConnectorConfig.java | 43 ++++++++++++++++++++++
.../kafka/connect/runtime/WorkerSinkTask.java | 8 ++--
.../kafka/connect/runtime/AbstractHerderTest.java | 30 +++++++++++++++
3 files changed, 76 insertions(+), 5 deletions(-)
