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

Posted to commits@kafka.apache.org by da...@apache.org on 2024/05/13 09:19:15 UTC

(kafka) branch trunk updated (cfffe4e2e85 -> ee16eee5deb)

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

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


    from cfffe4e2e85 KAFKA-10199: Handle assignment with new remove operation in state updater (#15882)
     add ee16eee5deb KAFKA-16587: Add subscription model information to group state (#15785)

No new revisions were added by this update.

Summary of changes:
 .../coordinator/group/GroupMetadataManager.java    |  51 ++++++++---
 .../coordinator/group/assignor/AssignmentSpec.java |  24 ++++-
 .../coordinator/group/assignor/RangeAssignor.java  |  57 ++++++++----
 .../group/assignor/SubscriptionType.java           |  35 ++++---
 .../group/assignor/UniformAssignor.java            |  26 +-----
 .../coordinator/group/consumer/ConsumerGroup.java  |  94 +++++++++++++++----
 .../group/consumer/TargetAssignmentBuilder.java    |  21 ++++-
 .../group/OffsetMetadataManagerTest.java           |   3 +-
 .../GeneralUniformAssignmentBuilderTest.java       |  33 +++----
 .../OptimizedUniformAssignmentBuilderTest.java     |  37 ++++----
 .../group/assignor/RangeAssignorTest.java          |  24 ++---
 .../group/consumer/ConsumerGroupTest.java          | 102 ++++++++++++++++-----
 .../consumer/TargetAssignmentBuilderTest.java      |   6 +-
 .../jmh/assignor/ClientSideAssignorBenchmark.java  |   9 +-
 .../jmh/assignor/ServerSideAssignorBenchmark.java  |  24 ++---
 .../assignor/TargetAssignmentBuilderBenchmark.java |   4 +-
 16 files changed, 368 insertions(+), 182 deletions(-)
 copy streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueBytesStoreSupplier.java => group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/SubscriptionType.java (60%)