This is an automated email from the ASF dual-hosted git repository.
manikumar pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 15eb555b031 MINOR: Fix the typo in RaftEventSimulationTest.java and
ControllerNode.java (#16591)
add 0b6086ed88e KAFKA-16741: Add ShareGroupHeartbeat API support - 2/N
(KIP-932) (#16573)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../scala/unit/kafka/server/KafkaConfigTest.scala | 38 +-
.../group/CoordinatorRecordHelpers.java | 141 ++-
.../coordinator/group/GroupCoordinatorConfig.java | 123 ++
.../coordinator/group/GroupCoordinatorService.java | 21 +-
.../coordinator/group/GroupCoordinatorShard.java | 67 +-
.../coordinator/group/GroupMetadataManager.java | 1180 ++++++++++++++++++--
.../org/apache/kafka/coordinator/group/Utils.java | 13 +
.../coordinator/group/modern/share/ShareGroup.java | 6 +-
.../modern/share/ShareGroupAssignmentBuilder.java | 93 ++
.../group/modern/share/ShareGroupMember.java | 18 +
.../apache/kafka/coordinator/group/Assertions.java | 50 +
.../group/GroupCoordinatorConfigTest.java | 8 +-
.../group/GroupCoordinatorServiceTest.java | 105 +-
.../group/GroupCoordinatorShardTest.java | 148 +++
.../group/GroupMetadataManagerTest.java | 444 +++++++-
.../group/GroupMetadataManagerTestContext.java | 100 +-
.../coordinator/group/MockPartitionAssignor.java | 3 +-
.../coordinator/group/NoOpPartitionAssignor.java | 3 +-
.../kafka/server/config/AbstractKafkaConfig.java | 1 +
.../kafka/server/config/ShareGroupConfig.java | 100 +-
21 files changed, 2396 insertions(+), 268 deletions(-)
create mode 100644
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupAssignmentBuilder.java
