You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/06/05 17:41:33 UTC
[kafka] branch trunk updated (31c81a6 -> 9774c73)
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 31c81a6 fix the broken links of streams javadoc (#8789)
add 9774c73 KAFKA-9441: Improve Kafka Streams task management (#8776)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/StandbyTask.java | 85 +++++----
.../streams/processor/internals/StreamTask.java | 210 ++++++++++++++-------
.../kafka/streams/processor/internals/Task.java | 12 +-
.../streams/processor/internals/TaskManager.java | 55 +++---
.../processor/internals/StandbyTaskTest.java | 2 +-
.../processor/internals/StreamTaskTest.java | 10 +-
.../processor/internals/TaskManagerTest.java | 17 +-
7 files changed, 248 insertions(+), 143 deletions(-)