kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ableegold...@apache.org
Subject [kafka] branch trunk updated (43db8ac -> 48379bd)
Date Mon, 07 Jun 2021 22:40:08 GMT
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%)

Mime
View raw message