KAFKA-14462; [18/N] Add GroupCoordinatorService

checkstyle/import-control.xml

@@ -223,6 +223,8 @@
     <subpackage name="group">
       <allow pkg="org.apache.kafka.clients.consumer" />
       <allow pkg="org.apache.kafka.common.annotation" />
+      <allow pkg="org.apache.kafka.common.config" />
+      <allow pkg="org.apache.kafka.common.internals" />
       <allow pkg="org.apache.kafka.common.message" />
       <allow pkg="org.apache.kafka.common.metadata" />
       <allow pkg="org.apache.kafka.common.network" />
@@ -232,6 +234,7 @@
       <allow pkg="org.apache.kafka.deferred" />
       <allow pkg="org.apache.kafka.image"/>
       <allow pkg="org.apache.kafka.server.common"/>
+      <allow pkg="org.apache.kafka.server.record"/>
       <allow pkg="org.apache.kafka.server.util"/>
       <allow pkg="org.apache.kafka.test" />
       <allow pkg="org.apache.kafka.timeline" />

group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java

@@ -0,0 +1,74 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.kafka.coordinator.group;
+
+import org.apache.kafka.coordinator.group.assignor.PartitionAssignor;
+
+import java.util.List;
+
+/**
+ * The group coordinator configurations.
+ */
+public class GroupCoordinatorConfig {
+
+    /**
+     * The number of threads or event loops running.
+     */
+    public final int numThreads;
+
+    /**
+     * The consumer group session timeout in milliseconds.
+     */
+    public final int consumerGroupSessionTimeoutMs;
+
+    /**
+     * The consumer group heartbeat interval in milliseconds.
+     */
+    public final int consumerGroupHeartbeatIntervalMs;
+
+    /**
+     * The consumer group maximum size.
+     */
+    public final int consumerGroupMaxSize;
+
+    /**
+     * The consumer group assignors.
+     */
+    public final List<PartitionAssignor> consumerGroupAssignors;
+
+    /**
+     * The offsets topic segment bytes should be kept relatively small to facilitate faster
+     * log compaction and faster offset loads.
+     */
+    public final int offsetsTopicSegmentBytes;
+
+    public GroupCoordinatorConfig(
+        int numThreads,
+        int consumerGroupSessionTimeoutMs,
+        int consumerGroupHeartbeatIntervalMs,
+        int consumerGroupMaxSize,
+        List<PartitionAssignor> consumerGroupAssignors,
+        int offsetsTopicSegmentBytes
+    ) {
+        this.numThreads = numThreads;
+        this.consumerGroupSessionTimeoutMs = consumerGroupSessionTimeoutMs;
+        this.consumerGroupHeartbeatIntervalMs = consumerGroupHeartbeatIntervalMs;
+        this.consumerGroupMaxSize = consumerGroupMaxSize;
+        this.consumerGroupAssignors = consumerGroupAssignors;
+        this.offsetsTopicSegmentBytes = offsetsTopicSegmentBytes;
+    }
+}