This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from d5fd491 KAFKA-7106: remove deprecated Windows APIs (#10378)
add fb2eef9 KAFKA-12523: handle TaskCorruption and TimeoutException
during handleCorruption and handleRevocation (#10407)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/AbstractTask.java | 1 +
.../streams/processor/internals/StreamTask.java | 9 +-
.../streams/processor/internals/TaskManager.java | 155 +++++++----
.../kafka/streams/processor/internals/Tasks.java | 10 +
.../processor/internals/StreamTaskTest.java | 18 ++
.../processor/internals/TaskManagerTest.java | 293 +++++++++++++++++++++
6 files changed, 433 insertions(+), 53 deletions(-)
