This is an automated email from the ASF dual-hosted git repository.
rhauch pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from e8dcbb9 KAFKA-13472: Correct last-committed offsets tracking for sink
tasks after partial revocation (#11526)
add f875576 KAFKA-13469: Block for in-flight record delivery before
end-of-life source task offset commit (#11524)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/runtime/SubmittedRecords.java | 59 ++++++++++++--
.../kafka/connect/runtime/WorkerSourceTask.java | 6 +-
.../connect/runtime/SubmittedRecordsTest.java | 94 +++++++++++++++++++++-
3 files changed, 149 insertions(+), 10 deletions(-)
