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 59a75f4 KAFKA-9048 Pt1: Remove Unnecessary lookup in Fetch Building
(#7576)
add 56bc507 MINOR: improve logging of tasks on shutdown (#7597)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/AbstractTask.java | 5 +-
.../processor/internals/AssignedStandbyTasks.java | 10 ++++
.../processor/internals/AssignedStreamsTasks.java | 62 +++++++++++++---------
.../streams/processor/internals/AssignedTasks.java | 2 +-
.../processor/internals/StoreChangelogReader.java | 2 +
.../streams/processor/internals/TaskManager.java | 7 +--
.../internals/AssignedStreamsTasksTest.java | 2 +-
.../processor/internals/StreamTaskTest.java | 11 ++--
.../processor/internals/StreamThreadTest.java | 18 ++++---
.../processor/internals/TaskManagerTest.java | 4 +-
10 files changed, 75 insertions(+), 48 deletions(-)
