You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ab...@apache.org on 2021/06/07 22:40:08 UTC
[kafka] branch trunk updated (43db8ac -> 48379bd)

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

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


    from 43db8ac  KAFKA-12897: KRaft multi-partition placement on single broker (#10823)
     add 48379bd  KAFKA-12648: Pt. 1 - Add NamedTopology to protocol and state directory structure (#10609)

No new revisions were added by this update.

Summary of changes:
 checkstyle/suppressions.xml                        |   2 +-
 .../org/apache/kafka/streams/KafkaStreams.java     |   2 +-
 .../internals/InternalTopologyBuilder.java         |   5 +
 .../processor/internals/StateDirectory.java        | 230 ++++++++++++++++-----
 .../internals/StreamsPartitionAssignor.java        |   1 +
 .../streams/processor/internals/TaskManager.java   |   8 +-
 .../internals/assignment/AssignmentInfo.java       |   2 +
 .../assignment/ConsumerProtocolUtils.java          |   5 +
 .../StreamsAssignmentProtocolVersions.java         |  16 +-
 .../internals/assignment/SubscriptionInfo.java     |  47 ++++-
 .../internals/namedtopology/NamedTopology.java     |   5 +-
 .../common/message/SubscriptionInfoData.json       |  39 +++-
 .../org/apache/kafka/streams/KafkaStreamsTest.java |   8 +-
 .../integration/NamedTopologyIntegrationTest.java  |  32 ++-
 .../processor/internals/StateDirectoryTest.java    | 225 +++++++++++++-------
 .../processor/internals/TaskManagerTest.java       |  13 +-
 .../internals/assignment/AssignmentInfoTest.java   |  69 ++++++-
 .../internals/assignment/AssignmentTestUtils.java  |  12 +-
 .../internals/assignment/SubscriptionInfoTest.java |  44 ++++
 .../StreamThreadStateStoreProviderTest.java        |   2 +-
 .../apache/kafka/streams/TopologyTestDriver.java   |   2 +-
 .../tests/streams/streams_upgrade_test.py          |   5 +-
 22 files changed, 595 insertions(+), 179 deletions(-)
 copy clients/src/main/java/org/apache/kafka/clients/admin/UnregisterBrokerResult.java => streams/src/test/java/org/apache/kafka/streams/integration/NamedTopologyIntegrationTest.java (55%)