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 a989149 KAFKA-13200: Fix MirrorMaker2 connector version (#11212)
add e8dcbb9 KAFKA-13472: Correct last-committed offsets tracking for sink
tasks after partial revocation (#11526)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/runtime/WorkerSinkTask.java | 14 +--
.../kafka/connect/tools/VerifiableSinkTask.java | 33 ++++--
.../kafka/connect/runtime/WorkerSinkTaskTest.java | 129 +++++++++++++++++++++
3 files changed, 157 insertions(+), 19 deletions(-)
