You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by gu...@apache.org on 2020/05/27 17:41:34 UTC

[kafka] branch trunk updated (33c8774 -> 99115cb)

This is an automated email from the ASF dual-hosted git repository.

guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 33c8774  KAFKA-9353; Add groupInstanceId to DescribeGroup for better visibility (#7886)
     add 99115cb  KAFKA-9561: Update task input partitions after rebalance (#8221)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/AbstractTask.java  |  16 +-
 .../processor/internals/PartitionGroup.java        |  25 +++
 .../streams/processor/internals/StreamTask.java    |  94 ++++++----
 .../kafka/streams/processor/internals/Task.java    |   5 +
 .../streams/processor/internals/TaskManager.java   |  28 ++-
 .../integration/RegexSourceIntegrationTest.java    |  46 ++++-
 .../processor/internals/PartitionGroupTest.java    | 198 ++++++++++++++++-----
 .../processor/internals/StreamTaskTest.java        |   2 +-
 .../processor/internals/TaskManagerTest.java       |  33 +++-
 9 files changed, 356 insertions(+), 91 deletions(-)