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

Posted to commits@kafka.apache.org by vv...@apache.org on 2020/03/06 15:19:48 UTC

[kafka] branch trunk updated (78374a1 -> 674360f)

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

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


    from 78374a1  KAFKA-9615: Clean up task/producer create and close (#8213)
     add 674360f  KAFKA-6145: Encode task positions in SubscriptionInfo (#8121)

No new revisions were added by this update.

Summary of changes:
 .../internals/StreamsPartitionAssignor.java        |  71 +++----
 .../kafka/streams/processor/internals/Task.java    |   2 +-
 .../streams/processor/internals/TaskManager.java   |  24 ++-
 .../internals/assignment/AssignmentInfo.java       |   2 +
 .../StreamsAssignmentProtocolVersions.java         |   2 +-
 .../internals/assignment/SubscriptionInfo.java     | 131 +++++++++---
 .../resources/common/message/SubscriptionInfo.json |  43 +++-
 .../internals/StreamsPartitionAssignorTest.java    | 223 ++++++++++-----------
 .../processor/internals/TaskManagerTest.java       |   8 +-
 .../internals/assignment/AssignmentInfoTest.java   |   4 +-
 .../assignment/LegacySubscriptionInfoSerde.java    |   7 +-
 .../internals/assignment/SubscriptionInfoTest.java | 130 +++++++-----
 .../kafka/streams/tests/StreamsUpgradeTest.java    |  53 ++---
 .../tests/streams/streams_upgrade_test.py          |  12 +-
 14 files changed, 418 insertions(+), 294 deletions(-)