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 c6664e1 MINOR: Move the resetting from revoked to the thread loop
(#7243)
add 237e83d KAFKA-8586: Fail source tasks when producers fail to send
records (#6993)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/connect/runtime/Worker.java | 4 +-
.../kafka/connect/runtime/WorkerSourceTask.java | 25 ++++++++---
.../connect/runtime/WorkerSourceTaskTest.java | 51 +++++++++++++++++-----
3 files changed, 61 insertions(+), 19 deletions(-)
