This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 2552aa3 KAFKA-10671: improve the partition.assignment.strategy docs
(#9788)
add 3931390 MINOR: code cleanup for Kafka Streams task interface (#9801)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/AbstractTask.java | 7 +-
.../processor/internals/ActiveTaskCreator.java | 10 +-
.../streams/processor/internals/StandbyTask.java | 4 +-
.../processor/internals/StandbyTaskCreator.java | 10 +-
.../streams/processor/internals/StreamTask.java | 8 +-
.../kafka/streams/processor/internals/Task.java | 162 ++++++++++++---------
.../streams/processor/internals/TaskManager.java | 2 +-
.../processor/internals/StreamTaskTest.java | 2 +-
.../processor/internals/TaskManagerTest.java | 2 +-
9 files changed, 110 insertions(+), 97 deletions(-)
