This is an automated email from the ASF dual-hosted git repository.
cegerton pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 5d597b0fc81 MINOR: Replace BrokerMetadataListener with MetadataLoader
(#13344)
add 404a833df7d KAFKA-14799: Ignore source task requests to abort empty
transactions (#13379)
No new revisions were added by this update.
Summary of changes:
.../kafka/connect/source/TransactionContext.java | 10 ++
.../connect/runtime/AbstractWorkerSourceTask.java | 5 +-
.../runtime/ExactlyOnceWorkerSourceTask.java | 10 +-
.../runtime/ExactlyOnceWorkerSourceTaskTest.java | 144 ++++++++++++++++++++-
4 files changed, 160 insertions(+), 9 deletions(-)
