KAFKA-14462; [23/23] Wire GroupCoordinatorService in BrokerServer #13991

dajac · 2023-07-11T11:29:15Z

This is the last patch for KAFKA-14462. It wires all the pieces together in BrokerServer.

Committer Checklist (excluded from commit message)

Verify design and implementation
Verify test coverage and CI build status
Verify documentation (including upgrade notes)

core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala

core/src/main/scala/kafka/server/KafkaConfig.scala

group-coordinator/src/main/java/org/apache/kafka/coordinator/group/util/SystemTimerReaper.java

...p-coordinator/src/test/java/org/apache/kafka/coordinator/group/GroupMetadataManagerTest.java

...coordinator/src/test/java/org/apache/kafka/coordinator/group/util/SystemTimerReaperTest.java

group-coordinator/src/main/java/org/apache/kafka/coordinator/group/util/SystemTimerReaper.java

…ache#13991) This patch wires the new group coordinator in BrokerServer (KRaft only). With this, it is now possible to run a cluster with the new group coordinator and to use the ConsumerGroupHeartbeat API by specifying the following two properties: - group.coordinator.new.enable = true (to enable the new group coordinator) - unstable.api.versions.enable = true (to enable unreleased APIs) Note that the new group coordinator does not support all the existing APIs yet. Reviewers: Jeff Kim <jeff.kim@confluent.io>, Justine Olshan <jolshan@confluent.io>

dajac added the KIP-848 label Jul 11, 2023

dajac force-pushed the KAFKA-14462-23 branch from c47a9e3 to 57b5b98 Compare July 11, 2023 11:45

jeffkbkim reviewed Jul 12, 2023

View reviewed changes

core/src/test/scala/unit/kafka/server/ConsumerGroupHeartbeatRequestTest.scala Show resolved Hide resolved

KAFKA-14462; [23/23] Wire GroupCoordinatorService in BrokerServer

1c84328

dajac force-pushed the KAFKA-14462-23 branch from 57b5b98 to 1c84328 Compare July 12, 2023 09:11

dajac marked this pull request as ready for review July 12, 2023 09:12