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	7
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	69
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java	187
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	157
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java	424
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java	550
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	1064
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java	595
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java	4156
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetAndMetadata.java	120
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetConfig.java	33
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	761
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	137
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	169
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	87
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	386
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHomogeneousAssignmentBuilder.java	147
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java	804
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroupMember.java	201
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	373
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShard.java	196
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	79
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	273
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	43
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	309
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	394
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/CurrentAssignmentBuilder.java	163
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	181
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	128
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupMember.java	219
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/CurrentAssignmentBuilder.java	249
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	338
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroupMember.java	275
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsTopology.java	37
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	72
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TopicMetadata.java	41
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	17
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	54
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredInternalTopic.java	36
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredSubtopology.java	27
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredTopology.java	37
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/CopartitionedTopicsEnforcer.java	109
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/InternalTopicManager.java	242
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