Path	Lines of Code
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/ConsumerGroupPartitionAssignor.java	3
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupAssignment.java	29
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/GroupSpec.java	10
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberAssignment.java	7
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/MemberSubscription.java	9
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignor.java	8
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/PartitionAssignorException.java	10
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/ShareGroupPartitionAssignor.java	5
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscribedTopicDescriber.java	8
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/SubscriptionType.java	13
group-coordinator/group-coordinator-api/src/main/java/org/apache/kafka/coordinator/group/api/assignor/package-info.java	1
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/ConsumerGroupMigrationPolicy.java	39
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java	74
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java	280
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfigManager.java	42
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java	172
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java	564
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java	599
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordSerde.java	23
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java	1746
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java	868
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java	5425
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetAndMetadata.java	120
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetExpirationCondition.java	4
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetExpirationConditionImpl.java	19
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java	757
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/ShareGroupAutoOffsetResetStrategy.java	99
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java	185
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/AssignorHelpers.java	21
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeAssignor.java	168
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/RangeSet.java	122
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/SimpleAssignor.java	252
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformAssignor.java	37
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHeterogeneousAssignmentBuilder.java	385
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHomogeneousAssignmentBuilder.java	146
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java	806
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroupMember.java	200
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroupState.java	39
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetrics.java	475
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShard.java	149
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorRuntimeMetrics.java	9
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/Assignment.java	57
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/GroupSpecImpl.java	78
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/MemberAssignmentImpl.java	31
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/MemberState.java	30
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/MemberSubscriptionAndAssignmentImpl.java	67
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroup.java	274
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroupMember.java	78
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/SubscribedTopicDescriberImpl.java	60
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/SubscriptionCount.java	58
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java	316
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TopicIds.java	220
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TopicMetadata.java	79
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/UnionSet.java	171
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java	754
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupMember.java	393
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilder.java	162
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ResolvedRegularExpression.java	43
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroup.java	186
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupAssignmentBuilder.java	30
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java	121
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupMember.java	218
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/CurrentAssignmentBuilder.java	248
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/MemberState.java	29
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsCoordinatorRecordHelpers.java	327
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java	623
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupHeartbeatResult.java	12
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMember.java	289
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsTopology.java	44
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilder.java	187
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TasksTuple.java	126
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TopicMetadata.java	28
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TopologyMetadata.java	45
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/AssignmentMemberSpec.java	28
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupAssignment.java	8
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpec.java	6
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/GroupSpecImpl.java	10
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MemberAssignment.java	16
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/MockAssignor.java	70
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/ProcessState.java	104
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/StickyTaskAssignor.java	344
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TaskAssignor.java	8
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TaskAssignorException.java	10
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TaskId.java	14
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/assignor/TopologyDescriber.java	8
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ChangelogTopics.java	53
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredInternalTopic.java	34
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredSubtopology.java	26
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredTopology.java	36
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/CopartitionedTopicsEnforcer.java	108
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/EndpointToPartitionsManager.java	62
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/InternalTopicManager.java	235
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/RepartitionTopics.java	110
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/TopicConfigurationException.java	22