apache / kafka
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
17% | 15% | 25% | 18% | 22%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java16% | 14% | 25% | 18% | 23%
scala32% | 26% | 21% | 13% | 6%
py0% | 0% | 38% | 0% | 61%
xml0% | 0% | 91% | 0% | 8%
xsl0% | 0% | 0% | 100% | 0%
yaml0% | 0% | 0% | 53% | 46%
rdf0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
clients14% | 15% | 19% | 18% | 30%
streams17% | 13% | 28% | 18% | 22%
core34% | 26% | 19% | 14% | 4%
group-coordinator34% | 24% | 20% | 12% | 8%
connect14% | 16% | 27% | 17% | 23%
metadata17% | 5% | 29% | 24% | 22%
storage20% | 16% | 26% | 17% | 19%
raft24% | 17% | 26% | 16% | 14%
tools12% | 27% | 44% | 9% | 5%
generator26% | 8% | 32% | 16% | 16%
coordinator-common53% | 0% | 0% | 21% | 25%
server-common11% | 0% | 22% | 25% | 40%
share-coordinator0% | 63% | 9% | 18% | 8%
server0% | 15% | 16% | 19% | 47%
trogdor0% | 0% | 50% | 17% | 32%
jmh-benchmarks0% | 0% | 39% | 38% | 22%
gradle0% | 0% | 66% | 30% | 3%
committer-tools0% | 0% | 49% | 0% | 50%
shell0% | 0% | 12% | 35% | 51%
release0% | 0% | 38% | 0% | 61%
transaction-coordinator0% | 0% | 0% | 38% | 61%
config0% | 0% | 0% | 72% | 27%
docker0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
test-common0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
GroupMetadataManager.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 5425 228
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4131 156
KafkaApis.scala
in core/src/main/scala/kafka/server
 3343 94
KafkaRaftClient.java
in raft/src/main/java/org/apache/kafka/raft
 3122 152
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 2304 127
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2203 86
SharePartition.java
in core/src/main/java/kafka/server/share
 2060 116
ReplicationControlManager.java
in metadata/src/main/java/org/apache/kafka/controller
 1975 80
InternalTopologyBuilder.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1852 162
UnifiedLog.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 1748 155
GroupCoordinatorService.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 1746 58
TaskManager.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1727 116
Worker.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1718 94
RemoteLogManager.java
in storage/src/main/java/org/apache/kafka/server/log/remote/storage
 1657 110
QuorumController.java
in metadata/src/main/java/org/apache/kafka/controller
 1654 110
AsyncKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1650 111
MessageDataGenerator.java
in generator/src/main/java/org/apache/kafka/message
 1611 51
StreamThread.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1511 68
CoordinatorRuntime.java
in coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime
 1472 85
RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 1435 302
KafkaStreams.java
in streams/src/main/java/org/apache/kafka/streams
 1397 81
TransactionManager.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 1385 130
StreamsConfig.java
in streams/src/main/java/org/apache/kafka/streams
 1371 49
Partition.scala
in core/src/main/scala/kafka/cluster
 1320 75
StreamsPartitionAssignor.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1257 48
SocketServer.scala
in core/src/main/scala/kafka/network
 1249 87
ConsumerCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1203 56
KTableImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1174 68
AbstractCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1170 83
ConsumerGroupCommand.java
in tools/src/main/java/org/apache/kafka/tools/consumer/group
 1164 44
PersisterStateManager.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 1156 75
NetworkClient.java
in clients/src/main/java/org/apache/kafka/clients
 1124 87
KStreamImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1118 80
ShareConsumeRequestManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1114 61
LogManager.scala
in core/src/main/scala/kafka/log
 1098 58
ReassignPartitionsCommand.java
in tools/src/main/java/org/apache/kafka/tools/reassign
 1054 37
Values.java
in connect/api/src/main/java/org/apache/kafka/connect/data
 1048 73
ConfigDef.java
in clients/src/main/java/org/apache/kafka/common/config
 1043 104
AbstractHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1033 67
Selector.java
in clients/src/main/java/org/apache/kafka/common/network
 1030 80
StreamTask.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1027 69
AbstractStickyAssignor.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1024 49
ClassicKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1002 68
ControllerApis.scala
in core/src/main/scala/kafka/server
 975 44
CommitRequestManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 965 61
DefaultStateUpdater.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 955 77
SubscriptionState.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 954 143
Utils.java
in clients/src/main/java/org/apache/kafka/common/utils
 924 89
Type.java
in clients/src/main/java/org/apache/kafka/common/protocol/types
 910 138
LeaderState.java
in raft/src/main/java/org/apache/kafka/raft
 874 66
Files With Most Units (Top 50)
File# lines# units
RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 1435 302
GroupMetadataManager.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 5425 228
InternalTopologyBuilder.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1852 162
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4131 156
UnifiedLog.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 1748 155
KafkaRaftClient.java
in raft/src/main/java/org/apache/kafka/raft
 3122 152
SubscriptionState.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 954 143
Type.java
in clients/src/main/java/org/apache/kafka/common/protocol/types
 910 138
LogContext.java
in clients/src/main/java/org/apache/kafka/common/utils
 636 131
TransactionManager.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 1385 130
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 2304 127
SharePartition.java
in core/src/main/java/kafka/server/share
 2060 116
TaskManager.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1727 116
AsyncKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1650 111
QuorumController.java
in metadata/src/main/java/org/apache/kafka/controller
 1654 110
RemoteLogManager.java
in storage/src/main/java/org/apache/kafka/server/log/remote/storage
 1657 110
ConfigDef.java
in clients/src/main/java/org/apache/kafka/common/config
 1043 104
KafkaApis.scala
in core/src/main/scala/kafka/server
 3343 94
Worker.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1718 94
Utils.java
in clients/src/main/java/org/apache/kafka/common/utils
 924 89
SocketServer.scala
in core/src/main/scala/kafka/network
 1249 87
NetworkClient.java
in clients/src/main/java/org/apache/kafka/clients
 1124 87
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2203 86
CoordinatorRuntime.java
in coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime
 1472 85
Struct.java
in clients/src/main/java/org/apache/kafka/common/protocol/types
 432 85
AbstractCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1170 83
ClassicGroup.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic
 806 82
KafkaStreams.java
in streams/src/main/java/org/apache/kafka/streams
 1397 81
ReplicationControlManager.java
in metadata/src/main/java/org/apache/kafka/controller
 1975 80
KStreamImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1118 80
Selector.java
in clients/src/main/java/org/apache/kafka/common/network
 1030 80
DefaultStateUpdater.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 955 77
MockConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 557 77
PersisterStateManager.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 1156 75
Partition.scala
in core/src/main/scala/kafka/cluster
 1320 75
StreamsMetricsImpl.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics
 829 75
Values.java
in connect/api/src/main/java/org/apache/kafka/connect/data
 1048 73
TopologyTestDriver.java
in streams/test-utils/src/main/java/org/apache/kafka/streams
 858 72
TopicCommand.java
in tools/src/main/java/org/apache/kafka/tools
 834 71
MemoryRecordsBuilder.java
in clients/src/main/java/org/apache/kafka/common/record
 567 70
Admin.java
in clients/src/main/java/org/apache/kafka/clients/admin
 351 70
AbstractMembershipManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 756 70
StreamsMembershipManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 829 70
FieldType.java
in generator/src/main/java/org/apache/kafka/message
 375 69
StreamTask.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1027 69
AbstractLegacyRecordBatch.java
in clients/src/main/java/org/apache/kafka/common/record
 464 69
StreamThread.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1511 68
KTableImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1174 68
ClassicKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1002 68
AbstractHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1033 67
Files With Long Lines (Top 50)

There are 1203 files with lines longer than 120 characters. In total, there are 9706 long lines.

File# lines# units# long lines
RequestConvertToJson.java
in server/src/main/java/org/apache/kafka/network
 794 6 144
Worker.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1718 94 139
KafkaApis.scala
in core/src/main/scala/kafka/server
 3343 94 135
GroupCoordinatorConfig.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 564 46 135
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 2304 127 131
ProducerConfig.java
in clients/src/main/java/org/apache/kafka/clients/producer
 528 11 123
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4131 156 119
UnifiedLog.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 1748 155 110
StreamsConfig.java
in streams/src/main/java/org/apache/kafka/streams
 1371 49 107
ConsumerGroupCommand.java
in tools/src/main/java/org/apache/kafka/tools/consumer/group
 1164 44 106
GroupMetadataManager.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 5425 228 106
RemoteLogManager.java
in storage/src/main/java/org/apache/kafka/server/log/remote/storage
 1657 110 103
CommonClientConfigs.java
in clients/src/main/java/org/apache/kafka/clients
 242 7 96
SharePartition.java
in core/src/main/java/kafka/server/share
 2060 116 87
SaslConfigs.java
in clients/src/main/java/org/apache/kafka/common/config
 176 1 87
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2203 86 81
LogConfig.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 540 41 79
BrokerSecurityConfigs.java
in clients/src/main/java/org/apache/kafka/common/config/internals
 158 - 78
ReassignPartitionsCommand.java
in tools/src/main/java/org/apache/kafka/tools/reassign
 1054 37 71
ConfigCommand.scala
in core/src/main/scala/kafka/admin
 582 18 69
ConnectMetricsRegistry.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 435 17 69
AclCommand.java
in tools/src/main/java/org/apache/kafka/tools
 531 19 63
PersisterStateManager.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 1156 75 62
ShareConsumeRequestManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1114 61 62
KafkaConfig.scala
in core/src/main/scala/kafka/server
 607 24 60
ConnectorConfig.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 608 30 60
RemoteLogManagerConfig.java
in storage/src/main/java/org/apache/kafka/server/log/remote/storage
 414 35 59
ReplicationConfigs.java
in server/src/main/java/org/apache/kafka/server/config
 121 - 57
KStreamImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1118 80 56
AbstractStickyAssignor.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1024 49 53
TopicCommand.java
in tools/src/main/java/org/apache/kafka/tools
 834 71 52
ShareCoordinatorShard.java
in share-coordinator/src/main/java/org/apache/kafka/coordinator/share
 733 41 51
SocketServerConfigs.java
in server/src/main/java/org/apache/kafka/network
 185 3 51
KafkaStreams.java
in streams/src/main/java/org/apache/kafka/streams
 1397 81 51
ServerLogConfigs.java
in server-common/src/main/java/org/apache/kafka/server/config
 110 - 49
TaskAssignmentUtils.java
in streams/src/main/java/org/apache/kafka/streams/processor/assignment
 780 33 49
TransactionStateManager.scala
in core/src/main/scala/kafka/coordinator/transaction
 647 25 47
ConsumerCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1203 56 47
ConsumerGroupCommandOptions.java
in tools/src/main/java/org/apache/kafka/tools/consumer/group
 244 3 45
DelayedShareFetch.java
in core/src/main/java/kafka/server/share
 650 31 45
GroupCoordinatorService.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 1746 58 45
ConsumerConfig.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 574 13 45
ConfigDef.java
in clients/src/main/java/org/apache/kafka/common/config
 1043 104 44
ServerConfigs.java
in server-common/src/main/java/org/apache/kafka/server/config
 102 - 43
StreamThread.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1511 68 43
KTableImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1174 68 43
DistributedConfig.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 573 29 42
DynamicBrokerConfig.scala
in core/src/main/scala/kafka/server
 851 62 41
TransactionCoordinator.scala
in core/src/main/scala/kafka/coordinator/transaction
 818 19 41
StreamsPartitionAssignor.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1257 48 41
Correlations

File Size vs. Commits (all time): 3541 points

clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 281 commits (all time) y: 4131 lines of code core/src/main/java/kafka/server/share/DelayedShareFetch.java x: 28 commits (all time) y: 650 lines of code core/src/main/java/kafka/server/share/SharePartition.java x: 58 commits (all time) y: 2060 lines of code core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 74 commits (all time) y: 548 lines of code core/src/main/scala/kafka/server/BrokerServer.scala x: 216 commits (all time) y: 642 lines of code core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 119 commits (all time) y: 851 lines of code raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 132 commits (all time) y: 3122 lines of code raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java x: 16 commits (all time) y: 220 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java x: 9 commits (all time) y: 93 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java x: 15 commits (all time) y: 292 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java x: 11 commits (all time) y: 114 lines of code raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java x: 16 commits (all time) y: 134 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java x: 5 commits (all time) y: 38 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java x: 5 commits (all time) y: 156 lines of code clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateSummaryResponse.java x: 5 commits (all time) y: 107 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 74 commits (all time) y: 1746 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java x: 6 commits (all time) y: 486 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java x: 3 commits (all time) y: 70 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionFactory.java x: 3 commits (all time) y: 31 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java x: 2 commits (all time) y: 8 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 21 commits (all time) y: 733 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java x: 14 commits (all time) y: 501 lines of code core/src/main/scala/kafka/server/ForwardingManager.scala x: 22 commits (all time) y: 146 lines of code server/src/main/java/org/apache/kafka/server/metrics/ForwardingManagerMetrics.java x: 1 commits (all time) y: 88 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsOptions.java x: 3 commits (all time) y: 13 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 137 commits (all time) y: 492 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java x: 16 commits (all time) y: 1164 lines of code server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchGroupKey.java x: 2 commits (all time) y: 39 lines of code core/src/main/java/kafka/server/share/PendingRemoteFetches.java x: 1 commits (all time) y: 56 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java x: 9 commits (all time) y: 186 lines of code clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 63 commits (all time) y: 525 lines of code server/src/main/java/org/apache/kafka/server/AssignmentsManager.java x: 18 commits (all time) y: 367 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 325 commits (all time) y: 290 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 102 commits (all time) y: 1650 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java x: 18 commits (all time) y: 854 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 89 commits (all time) y: 557 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java x: 9 commits (all time) y: 1748 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 135 commits (all time) y: 5425 lines of code tools/src/main/java/org/apache/kafka/tools/AdminCommandFailedException.java x: 1 commits (all time) y: 9 lines of code tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java x: 4 commits (all time) y: 137 lines of code tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java x: 7 commits (all time) y: 323 lines of code tools/src/main/java/org/apache/kafka/tools/TopicCommand.java x: 17 commits (all time) y: 834 lines of code tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java x: 18 commits (all time) y: 1054 lines of code core/src/main/java/kafka/server/TierStateMachine.java x: 10 commits (all time) y: 169 lines of code core/src/main/scala/kafka/cluster/Partition.scala x: 310 commits (all time) y: 1320 lines of code core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 164 commits (all time) y: 680 lines of code metadata/src/main/java/org/apache/kafka/controller/OffsetControlManager.java x: 8 commits (all time) y: 244 lines of code metadata/src/main/java/org/apache/kafka/controller/QuorumController.java x: 139 commits (all time) y: 1654 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 44 commits (all time) y: 719 lines of code raft/src/main/java/org/apache/kafka/raft/RaftClient.java x: 30 commits (all time) y: 38 lines of code raft/src/main/java/org/apache/kafka/raft/RaftUtil.java x: 16 commits (all time) y: 653 lines of code raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java x: 27 commits (all time) y: 77 lines of code raft/src/main/java/org/apache/kafka/raft/ValidOffsetAndEpoch.java x: 6 commits (all time) y: 52 lines of code raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java x: 7 commits (all time) y: 61 lines of code raft/src/main/java/org/apache/kafka/snapshot/NotifyingRawSnapshotWriter.java x: 3 commits (all time) y: 46 lines of code raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotReader.java x: 7 commits (all time) y: 10 lines of code raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotWriter.java x: 5 commits (all time) y: 13 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java x: 19 commits (all time) y: 207 lines of code raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java x: 9 commits (all time) y: 11 lines of code raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java x: 16 commits (all time) y: 13 lines of code server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java x: 55 commits (all time) y: 236 lines of code server-common/src/main/java/org/apache/kafka/server/common/ShareVersion.java x: 2 commits (all time) y: 49 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListTransactionsHandler.java x: 7 commits (all time) y: 105 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala x: 72 commits (all time) y: 818 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala x: 91 commits (all time) y: 647 lines of code core/src/main/scala/kafka/server/KafkaApis.scala x: 742 commits (all time) y: 3343 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java x: 13 commits (all time) y: 873 lines of code core/src/main/java/kafka/server/share/SharePartitionManager.java x: 56 commits (all time) y: 549 lines of code server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java x: 4 commits (all time) y: 91 lines of code clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 58 commits (all time) y: 242 lines of code streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/StickyTaskAssignor.java x: 9 commits (all time) y: 380 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommandOptions.java x: 7 commits (all time) y: 175 lines of code core/src/main/java/kafka/server/builders/KafkaApisBuilder.java x: 25 commits (all time) y: 188 lines of code core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala x: 46 commits (all time) y: 246 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java x: 10 commits (all time) y: 121 lines of code core/src/main/scala/kafka/server/KafkaConfig.scala x: 511 commits (all time) y: 607 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java x: 46 commits (all time) y: 564 lines of code server-common/src/main/java/org/apache/kafka/server/common/Feature.java x: 5 commits (all time) y: 186 lines of code core/src/main/scala/kafka/network/SocketServer.scala x: 209 commits (all time) y: 1249 lines of code core/src/main/scala/kafka/server/ControllerServer.scala x: 116 commits (all time) y: 379 lines of code core/src/main/scala/kafka/tools/TestRaftServer.scala x: 56 commits (all time) y: 397 lines of code core/src/main/scala/kafka/utils/CoreUtils.scala x: 55 commits (all time) y: 116 lines of code metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistration.java x: 26 commits (all time) y: 333 lines of code metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java x: 4 commits (all time) y: 261 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java x: 14 commits (all time) y: 194 lines of code server-common/src/main/java/org/apache/kafka/server/network/EndpointReadyFutures.java x: 6 commits (all time) y: 152 lines of code tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java x: 15 commits (all time) y: 443 lines of code clients/src/main/java/org/apache/kafka/common/metrics/internals/PluginMetricsImpl.java x: 2 commits (all time) y: 85 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java x: 11 commits (all time) y: 522 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java x: 5 commits (all time) y: 298 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 386 commits (all time) y: 1511 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java x: 41 commits (all time) y: 69 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 16 commits (all time) y: 1002 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java x: 208 commits (all time) y: 118 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 163 commits (all time) y: 796 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java x: 51 commits (all time) y: 171 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java x: 54 commits (all time) y: 206 lines of code clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 154 commits (all time) y: 924 lines of code core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala x: 19 commits (all time) y: 127 lines of code core/src/main/scala/kafka/server/DelayedProduce.scala x: 32 commits (all time) y: 88 lines of code core/src/main/scala/kafka/server/ReplicaManager.scala x: 484 commits (all time) y: 2203 lines of code clients/src/main/java/org/apache/kafka/clients/producer/PreparedTxnState.java x: 1 commits (all time) y: 65 lines of code tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java x: 3 commits (all time) y: 331 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListConsumerGroupOffsetsHandler.java x: 11 commits (all time) y: 167 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 52 commits (all time) y: 965 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 189 commits (all time) y: 1203 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java x: 36 commits (all time) y: 200 lines of code core/src/main/scala/kafka/log/LogManager.scala x: 246 commits (all time) y: 1098 lines of code core/src/main/scala/kafka/server/AbstractFetcherManager.scala x: 56 commits (all time) y: 184 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java x: 70 commits (all time) y: 292 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java x: 8 commits (all time) y: 76 lines of code clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 71 commits (all time) y: 351 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 21 commits (all time) y: 285 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java x: 59 commits (all time) y: 868 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManager.java x: 3 commits (all time) y: 1657 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java x: 13 commits (all time) y: 599 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 22 commits (all time) y: 754 lines of code streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 248 commits (all time) y: 1397 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ReadOnlyTask.java x: 11 commits (all time) y: 187 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java x: 100 commits (all time) y: 245 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java x: 248 commits (all time) y: 1027 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java x: 59 commits (all time) y: 103 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java x: 13 commits (all time) y: 218 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 222 commits (all time) y: 1727 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 136 commits (all time) y: 858 lines of code metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java x: 8 commits (all time) y: 145 lines of code clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java x: 5 commits (all time) y: 50 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java x: 85 commits (all time) y: 1033 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java x: 21 commits (all time) y: 509 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java x: 14 commits (all time) y: 435 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java x: 51 commits (all time) y: 608 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorStatus.java x: 7 commits (all time) y: 22 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java x: 21 commits (all time) y: 422 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TaskStatus.java x: 6 commits (all time) y: 19 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java x: 13 commits (all time) y: 59 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 106 commits (all time) y: 1718 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java x: 31 commits (all time) y: 487 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 89 commits (all time) y: 754 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java x: 81 commits (all time) y: 274 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java x: 46 commits (all time) y: 412 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/entities/ConnectorStateInfo.java x: 7 commits (all time) y: 109 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 37 commits (all time) y: 556 lines of code clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 262 commits (all time) y: 831 lines of code clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java x: 59 commits (all time) y: 431 lines of code clients/src/main/java/org/apache/kafka/clients/producer/Producer.java x: 21 commits (all time) y: 36 lines of code clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 141 commits (all time) y: 528 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 110 commits (all time) y: 1385 lines of code clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java x: 9 commits (all time) y: 130 lines of code core/src/main/java/kafka/server/share/ShareFetchUtils.java x: 22 commits (all time) y: 175 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Readable.java x: 14 commits (all time) y: 51 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 118 commits (all time) y: 262 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java x: 16 commits (all time) y: 40 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java x: 20 commits (all time) y: 106 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java x: 11 commits (all time) y: 46 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java x: 10 commits (all time) y: 41 lines of code clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsResponse.java x: 47 commits (all time) y: 252 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java x: 13 commits (all time) y: 40 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java x: 9 commits (all time) y: 75 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java x: 23 commits (all time) y: 41 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteGroupsResponse.java x: 10 commits (all time) y: 57 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteRecordsResponse.java x: 17 commits (all time) y: 44 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsResponse.java x: 19 commits (all time) y: 41 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeDelegationTokenResponse.java x: 10 commits (all time) y: 97 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java x: 28 commits (all time) y: 112 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java x: 21 commits (all time) y: 44 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeQuorumResponse.java x: 10 commits (all time) y: 67 lines of code clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java x: 15 commits (all time) y: 43 lines of code clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java x: 67 commits (all time) y: 195 lines of code clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotResponse.java x: 9 commits (all time) y: 61 lines of code clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java x: 21 commits (all time) y: 137 lines of code clients/src/main/java/org/apache/kafka/common/requests/HeartbeatResponse.java x: 25 commits (all time) y: 39 lines of code clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java x: 35 commits (all time) y: 52 lines of code clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupResponse.java x: 29 commits (all time) y: 113 lines of code clients/src/main/java/org/apache/kafka/common/requests/ListOffsetsResponse.java x: 5 commits (all time) y: 69 lines of code clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java x: 63 commits (all time) y: 378 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java x: 40 commits (all time) y: 206 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java x: 43 commits (all time) y: 307 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java x: 19 commits (all time) y: 43 lines of code clients/src/main/java/org/apache/kafka/common/requests/SyncGroupResponse.java x: 24 commits (all time) y: 43 lines of code clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java x: 16 commits (all time) y: 84 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java x: 5 commits (all time) y: 829 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareGroupOffset.java x: 7 commits (all time) y: 200 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java x: 8 commits (all time) y: 160 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java x: 37 commits (all time) y: 109 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java x: 28 commits (all time) y: 757 lines of code metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java x: 36 commits (all time) y: 591 lines of code metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java x: 38 commits (all time) y: 376 lines of code raft/src/main/java/org/apache/kafka/raft/FollowerState.java x: 23 commits (all time) y: 220 lines of code raft/src/main/java/org/apache/kafka/raft/LeaderState.java x: 54 commits (all time) y: 874 lines of code raft/src/main/java/org/apache/kafka/raft/internals/KRaftVersionUpgrade.java x: 1 commits (all time) y: 30 lines of code raft/src/main/java/org/apache/kafka/raft/internals/UpdateVoterHandler.java x: 6 commits (all time) y: 242 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java x: 10 commits (all time) y: 148 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeShareGroupsHandler.java x: 9 commits (all time) y: 150 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java x: 7 commits (all time) y: 1156 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java x: 2 commits (all time) y: 359 lines of code core/src/main/scala/kafka/raft/RaftManager.scala x: 71 commits (all time) y: 244 lines of code core/src/main/scala/kafka/admin/ConfigCommand.scala x: 116 commits (all time) y: 582 lines of code core/src/main/scala/kafka/server/DynamicConfig.scala x: 32 commits (all time) y: 32 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java x: 20 commits (all time) y: 513 lines of code clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java x: 12 commits (all time) y: 15 lines of code core/src/main/scala/kafka/server/FetchSession.scala x: 29 commits (all time) y: 580 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 122 commits (all time) y: 574 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java x: 16 commits (all time) y: 335 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CompletedFetch.java x: 12 commits (all time) y: 279 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchCollector.java x: 8 commits (all time) y: 271 lines of code clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java x: 39 commits (all time) y: 164 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java x: 21 commits (all time) y: 219 lines of code raft/src/main/java/org/apache/kafka/raft/MetadataLogConfig.java x: 2 commits (all time) y: 123 lines of code core/src/main/scala/kafka/server/KafkaBroker.scala x: 30 commits (all time) y: 82 lines of code streams/src/main/java/org/apache/kafka/streams/query/Position.java x: 5 commits (all time) y: 93 lines of code metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java x: 62 commits (all time) y: 650 lines of code clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java x: 41 commits (all time) y: 101 lines of code coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 15 commits (all time) y: 1472 lines of code core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala x: 17 commits (all time) y: 243 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java x: 22 commits (all time) y: 74 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java x: 34 commits (all time) y: 172 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java x: 26 commits (all time) y: 806 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java x: 7 commits (all time) y: 623 lines of code core/src/main/scala/kafka/server/ControllerApis.scala x: 66 commits (all time) y: 975 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/KRaftMetadataRequestBenchmark.java x: 26 commits (all time) y: 210 lines of code tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommandOptions.java x: 2 commits (all time) y: 95 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java x: 22 commits (all time) y: 268 lines of code tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java x: 9 commits (all time) y: 255 lines of code server/src/main/java/org/apache/kafka/security/authorizer/AclEntry.java x: 6 commits (all time) y: 66 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java x: 24 commits (all time) y: 856 lines of code core/src/main/scala/kafka/server/ConfigHandler.scala x: 74 commits (all time) y: 122 lines of code core/src/main/scala/kafka/tools/TestRaftRequestHandler.scala x: 19 commits (all time) y: 81 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java x: 35 commits (all time) y: 74 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 133 commits (all time) y: 2304 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java x: 17 commits (all time) y: 729 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java x: 50 commits (all time) y: 494 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java x: 16 commits (all time) y: 155 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java x: 42 commits (all time) y: 197 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java x: 34 commits (all time) y: 393 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java x: 40 commits (all time) y: 501 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginsRecommenders.java x: 3 commits (all time) y: 195 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java x: 22 commits (all time) y: 158 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java x: 25 commits (all time) y: 137 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java x: 52 commits (all time) y: 345 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java x: 60 commits (all time) y: 503 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java x: 6 commits (all time) y: 315 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java x: 57 commits (all time) y: 868 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java x: 33 commits (all time) y: 287 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java x: 18 commits (all time) y: 160 lines of code server-common/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java x: 13 commits (all time) y: 383 lines of code core/src/main/scala/kafka/network/RequestChannel.scala x: 164 commits (all time) y: 372 lines of code core/src/main/scala/kafka/server/KafkaRequestHandler.scala x: 85 commits (all time) y: 168 lines of code config/log4j2.yaml x: 3 commits (all time) y: 112 lines of code server-common/src/main/java/org/apache/kafka/server/config/ServerLogConfigs.java x: 13 commits (all time) y: 110 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java x: 1 commits (all time) y: 462 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleanerManager.java x: 2 commits (all time) y: 502 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java x: 30 commits (all time) y: 540 lines of code tools/src/main/java/org/apache/kafka/tools/GroupsCommand.java x: 3 commits (all time) y: 241 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java x: 122 commits (all time) y: 731 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManagers.java x: 36 commits (all time) y: 329 lines of code clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java x: 62 commits (all time) y: 382 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java x: 62 commits (all time) y: 444 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java x: 53 commits (all time) y: 561 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 256 commits (all time) y: 1371 lines of code server/src/main/java/org/apache/kafka/network/metrics/RequestMetrics.java x: 4 commits (all time) y: 165 lines of code core/src/main/scala/kafka/server/ClientQuotaManager.scala x: 64 commits (all time) y: 405 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java x: 44 commits (all time) y: 139 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/PartitionCreationBench.java x: 37 commits (all time) y: 175 lines of code core/src/main/java/kafka/docker/Log4jConfiguration.java x: 2 commits (all time) y: 164 lines of code core/src/main/java/kafka/server/builders/ReplicaManagerBuilder.java x: 28 commits (all time) y: 101 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 27 commits (all time) y: 1114 lines of code clients/src/main/java/org/apache/kafka/clients/producer/Callback.java x: 13 commits (all time) y: 5 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LocalLog.java x: 9 commits (all time) y: 666 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java x: 170 commits (all time) y: 1170 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java x: 10 commits (all time) y: 756 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManager.java x: 6 commits (all time) y: 218 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java x: 5 commits (all time) y: 270 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java x: 53 commits (all time) y: 174 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java x: 12 commits (all time) y: 350 lines of code server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java x: 6 commits (all time) y: 202 lines of code storage/src/main/java/org/apache/kafka/server/purgatory/DelayedRemoteListOffsets.java x: 1 commits (all time) y: 146 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java x: 42 commits (all time) y: 236 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java x: 22 commits (all time) y: 442 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java x: 27 commits (all time) y: 414 lines of code storage/src/main/java/org/apache/kafka/storage/internals/epoch/LeaderEpochFileCache.java x: 18 commits (all time) y: 341 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegment.java x: 21 commits (all time) y: 531 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegments.java x: 6 commits (all time) y: 135 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogValidator.java x: 13 commits (all time) y: 460 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/ProducerStateManager.java x: 18 commits (all time) y: 444 lines of code storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicMetrics.java x: 5 commits (all time) y: 327 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/OffsetCommitCallback.java x: 10 commits (all time) y: 9 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/Aggregator.java x: 14 commits (all time) y: 5 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java x: 10 commits (all time) y: 233 lines of code raft/src/main/java/org/apache/kafka/raft/RequestManager.java x: 10 commits (all time) y: 241 lines of code raft/src/main/java/org/apache/kafka/raft/ResignedState.java x: 11 commits (all time) y: 106 lines of code raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java x: 27 commits (all time) y: 451 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java x: 46 commits (all time) y: 354 lines of code core/src/main/scala/kafka/server/RemoteLeaderEndPoint.scala x: 13 commits (all time) y: 167 lines of code core/src/main/scala/kafka/server/ReplicaFetcherThread.scala x: 175 commits (all time) y: 120 lines of code clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java x: 143 commits (all time) y: 284 lines of code metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 105 commits (all time) y: 1975 lines of code metadata/src/main/java/org/apache/kafka/image/ClusterImage.java x: 13 commits (all time) y: 70 lines of code metadata/src/main/java/org/apache/kafka/image/TopicDelta.java x: 14 commits (all time) y: 153 lines of code metadata/src/main/java/org/apache/kafka/metadata/PartitionRegistration.java x: 28 commits (all time) y: 404 lines of code gradle/spotbugs-exclude.xml x: 70 commits (all time) y: 339 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/SimpleAssignor.java x: 5 commits (all time) y: 252 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java x: 8 commits (all time) y: 316 lines of code clients/src/main/java/org/apache/kafka/common/protocol/MessageUtil.java x: 18 commits (all time) y: 207 lines of code clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java x: 60 commits (all time) y: 567 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java x: 92 commits (all time) y: 285 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnRequest.java x: 14 commits (all time) y: 41 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java x: 17 commits (all time) y: 154 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateAclsRequest.java x: 14 commits (all time) y: 101 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java x: 23 commits (all time) y: 81 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsRequest.java x: 17 commits (all time) y: 106 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java x: 22 commits (all time) y: 86 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsRequest.java x: 18 commits (all time) y: 88 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasRequest.java x: 6 commits (all time) y: 94 lines of code clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorRequest.java x: 16 commits (all time) y: 102 lines of code clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java x: 25 commits (all time) y: 49 lines of code clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java x: 36 commits (all time) y: 158 lines of code clients/src/main/java/org/apache/kafka/common/requests/RequestContext.java x: 19 commits (all time) y: 169 lines of code clients/src/main/java/org/apache/kafka/common/requests/SaslHandshakeRequest.java x: 17 commits (all time) y: 40 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java x: 31 commits (all time) y: 309 lines of code server-common/src/main/java/org/apache/kafka/server/common/CheckpointFile.java x: 12 commits (all time) y: 137 lines of code server-common/src/main/java/org/apache/kafka/server/config/QuotaConfig.java x: 4 commits (all time) y: 177 lines of code tools/src/main/java/org/apache/kafka/tools/ClientMetricsCommand.java x: 6 commits (all time) y: 296 lines of code metadata/src/main/java/org/apache/kafka/metadata/storage/Formatter.java x: 11 commits (all time) y: 390 lines of code clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java x: 73 commits (all time) y: 420 lines of code core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala x: 42 commits (all time) y: 379 lines of code tools/src/main/java/org/apache/kafka/tools/AclCommand.java x: 2 commits (all time) y: 531 lines of code clients/src/main/java/org/apache/kafka/common/record/FileRecords.java x: 43 commits (all time) y: 332 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeStreamsGroupsHandler.java x: 2 commits (all time) y: 233 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala x: 34 commits (all time) y: 418 lines of code generator/src/main/java/org/apache/kafka/message/checker/Unifier.java x: 2 commits (all time) y: 149 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala x: 55 commits (all time) y: 368 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java x: 42 commits (all time) y: 133 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java x: 46 commits (all time) y: 143 lines of code metadata/src/main/java/org/apache/kafka/controller/ClientQuotaControlManager.java x: 17 commits (all time) y: 265 lines of code metadata/src/main/java/org/apache/kafka/controller/PartitionChangeBuilder.java x: 30 commits (all time) y: 409 lines of code metadata/src/main/java/org/apache/kafka/image/TopicsDelta.java x: 13 commits (all time) y: 174 lines of code metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java x: 9 commits (all time) y: 209 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java x: 16 commits (all time) y: 427 lines of code metadata/src/main/java/org/apache/kafka/metadata/properties/MetaPropertiesEnsemble.java x: 9 commits (all time) y: 396 lines of code server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java x: 13 commits (all time) y: 490 lines of code clients/src/main/java/org/apache/kafka/common/utils/LogContext.java x: 5 commits (all time) y: 636 lines of code core/src/main/scala/kafka/coordinator/group/CoordinatorLoaderImpl.scala x: 15 commits (all time) y: 181 lines of code core/src/main/scala/kafka/server/LocalLeaderEndPoint.scala x: 14 commits (all time) y: 182 lines of code core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala x: 54 commits (all time) y: 156 lines of code core/src/main/scala/kafka/tools/DumpLogSegments.scala x: 125 commits (all time) y: 566 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/log/TestLinearWriteSpeed.java x: 4 commits (all time) y: 285 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadOnlyDecorator.java x: 12 commits (all time) y: 251 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java x: 39 commits (all time) y: 548 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java x: 5 commits (all time) y: 374 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java x: 47 commits (all time) y: 955 lines of code tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java x: 2 commits (all time) y: 384 lines of code clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupDescription.java x: 1 commits (all time) y: 116 lines of code clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupMemberDescription.java x: 1 commits (all time) y: 252 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindowedKStream.java x: 22 commits (all time) y: 40 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java x: 7 commits (all time) y: 406 lines of code clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java x: 83 commits (all time) y: 639 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java x: 146 commits (all time) y: 1174 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroup.java x: 11 commits (all time) y: 274 lines of code core/src/main/scala/kafka/server/BrokerLifecycleManager.scala x: 32 commits (all time) y: 408 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java x: 33 commits (all time) y: 244 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java x: 36 commits (all time) y: 135 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHeterogeneousAssignmentBuilder.java x: 7 commits (all time) y: 385 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroupMember.java x: 2 commits (all time) y: 200 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetrics.java x: 12 commits (all time) y: 475 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShard.java x: 14 commits (all time) y: 149 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupMember.java x: 6 commits (all time) y: 393 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupMember.java x: 4 commits (all time) y: 218 lines of code clients/src/main/java/org/apache/kafka/clients/admin/AlterReplicaLogDirsResult.java x: 6 commits (all time) y: 24 lines of code clients/src/main/java/org/apache/kafka/clients/admin/CreateTopicsOptions.java x: 9 commits (all time) y: 24 lines of code clients/src/main/java/org/apache/kafka/clients/admin/DescribeLogDirsResult.java x: 11 commits (all time) y: 29 lines of code storage/api/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogSegmentMetadata.java x: 10 commits (all time) y: 203 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 130 commits (all time) y: 1257 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java x: 47 commits (all time) y: 166 lines of code clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java x: 43 commits (all time) y: 541 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java x: 61 commits (all time) y: 176 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java x: 26 commits (all time) y: 242 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java x: 63 commits (all time) y: 536 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java x: 177 commits (all time) y: 1118 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 118 commits (all time) y: 1852 lines of code clients/src/main/java/org/apache/kafka/common/record/Records.java x: 22 commits (all time) y: 19 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java x: 12 commits (all time) y: 326 lines of code core/src/main/scala/kafka/docker/KafkaDockerWrapper.scala x: 10 commits (all time) y: 279 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java x: 45 commits (all time) y: 83 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java x: 37 commits (all time) y: 71 lines of code clients/src/main/java/org/apache/kafka/clients/ClientUtils.java x: 40 commits (all time) y: 224 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java x: 47 commits (all time) y: 184 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamSelfJoin.java x: 6 commits (all time) y: 109 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StateManagerUtil.java x: 23 commits (all time) y: 119 lines of code streams/src/main/java/org/apache/kafka/streams/state/QueryableStoreTypes.java x: 13 commits (all time) y: 101 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemorySessionStore.java x: 30 commits (all time) y: 458 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueChangeBuffer.java x: 4 commits (all time) y: 431 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/StreamThreadStateStoreProvider.java x: 25 commits (all time) y: 94 lines of code core/src/main/scala/kafka/server/AlterPartitionManager.scala x: 22 commits (all time) y: 215 lines of code core/src/main/scala/kafka/server/KafkaRaftServer.scala x: 50 commits (all time) y: 134 lines of code core/src/main/scala/kafka/tools/StorageTool.scala x: 42 commits (all time) y: 401 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/SessionWindows.java x: 30 commits (all time) y: 61 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/SessionWindowedKStreamImpl.java x: 25 commits (all time) y: 205 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java x: 23 commits (all time) y: 19 lines of code server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java x: 8 commits (all time) y: 794 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java x: 86 commits (all time) y: 789 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java x: 53 commits (all time) y: 37 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedTable.java x: 38 commits (all time) y: 39 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedStreamImpl.java x: 45 commits (all time) y: 206 lines of code streams/src/main/java/org/apache/kafka/streams/Topology.java x: 36 commits (all time) y: 449 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java x: 152 commits (all time) y: 183 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/KTable.java x: 79 commits (all time) y: 175 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkThread.java x: 18 commits (all time) y: 219 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CoordinatorRequestManager.java x: 21 commits (all time) y: 158 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/AbstractStream.java x: 43 commits (all time) y: 75 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java x: 21 commits (all time) y: 267 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java x: 46 commits (all time) y: 403 lines of code clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java x: 30 commits (all time) y: 122 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/LoggingResource.java x: 12 commits (all time) y: 80 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareCompletedFetch.java x: 5 commits (all time) y: 307 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java x: 75 commits (all time) y: 459 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java x: 54 commits (all time) y: 444 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java x: 67 commits (all time) y: 458 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java x: 99 commits (all time) y: 954 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKTableJoinProcessor.java x: 27 commits (all time) y: 138 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilder.java x: 1 commits (all time) y: 187 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Protocol.java x: 80 commits (all time) y: 193 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableFilter.java x: 30 commits (all time) y: 168 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableRepartitionMap.java x: 31 commits (all time) y: 150 lines of code metadata/src/main/java/org/apache/kafka/image/MetadataDelta.java x: 19 commits (all time) y: 367 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEvent.java x: 32 commits (all time) y: 61 lines of code streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java x: 47 commits (all time) y: 42 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java x: 34 commits (all time) y: 327 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java x: 26 commits (all time) y: 95 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java x: 55 commits (all time) y: 609 lines of code connect/api/src/main/java/org/apache/kafka/connect/data/Values.java x: 20 commits (all time) y: 1048 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java x: 35 commits (all time) y: 114 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java x: 89 commits (all time) y: 292 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java x: 58 commits (all time) y: 215 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractDualSchemaRocksDBSegmentedBytesStore.java x: 14 commits (all time) y: 250 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java x: 49 commits (all time) y: 410 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java x: 68 commits (all time) y: 473 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java x: 17 commits (all time) y: 77 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingWindowBytesStore.java x: 30 commits (all time) y: 100 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java x: 6 commits (all time) y: 572 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java x: 54 commits (all time) y: 829 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java x: 22 commits (all time) y: 341 lines of code clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java x: 40 commits (all time) y: 321 lines of code clients/src/main/java/org/apache/kafka/common/requests/RequestHeader.java x: 31 commits (all time) y: 115 lines of code generator/src/main/java/org/apache/kafka/message/MessageGenerator.java x: 25 commits (all time) y: 294 lines of code server/src/main/java/org/apache/kafka/network/SocketServerConfigs.java x: 10 commits (all time) y: 185 lines of code clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java x: 20 commits (all time) y: 9 lines of code clients/src/main/java/org/apache/kafka/clients/NetworkClient.java x: 147 commits (all time) y: 1124 lines of code clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java x: 25 commits (all time) y: 170 lines of code tools/src/main/java/org/apache/kafka/tools/BrokerApiVersionsCommand.java x: 2 commits (all time) y: 254 lines of code streams/src/main/java/org/apache/kafka/streams/TopologyDescription.java x: 18 commits (all time) y: 52 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBTimeOrderedKeyValueBuffer.java x: 8 commits (all time) y: 283 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java x: 76 commits (all time) y: 473 lines of code tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java x: 31 commits (all time) y: 547 lines of code clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslServer.java x: 13 commits (all time) y: 208 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java x: 22 commits (all time) y: 596 lines of code tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java x: 11 commits (all time) y: 612 lines of code core/src/main/scala/kafka/server/NodeToControllerChannelManager.scala x: 15 commits (all time) y: 273 lines of code clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java x: 53 commits (all time) y: 345 lines of code clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java x: 48 commits (all time) y: 530 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java x: 15 commits (all time) y: 199 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java x: 13 commits (all time) y: 1435 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java x: 14 commits (all time) y: 459 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecords.java x: 21 commits (all time) y: 84 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/JoinWindows.java x: 40 commits (all time) y: 104 lines of code core/src/main/scala/kafka/Kafka.scala x: 50 commits (all time) y: 75 lines of code clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java x: 38 commits (all time) y: 239 lines of code connect/api/src/main/java/org/apache/kafka/connect/data/SchemaBuilder.java x: 17 commits (all time) y: 228 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java x: 28 commits (all time) y: 327 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java x: 34 commits (all time) y: 597 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServerConfig.java x: 6 commits (all time) y: 326 lines of code generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java x: 46 commits (all time) y: 1611 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java x: 46 commits (all time) y: 218 lines of code streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java x: 11 commits (all time) y: 780 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java x: 62 commits (all time) y: 738 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java x: 12 commits (all time) y: 226 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java x: 41 commits (all time) y: 422 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/RackAwareTaskAssignor.java x: 18 commits (all time) y: 392 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/KafkaStreamsNamedTopologyWrapper.java x: 24 commits (all time) y: 265 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java x: 17 commits (all time) y: 446 lines of code tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java x: 8 commits (all time) y: 602 lines of code tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java x: 40 commits (all time) y: 441 lines of code connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java x: 37 commits (all time) y: 623 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java x: 20 commits (all time) y: 273 lines of code connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java x: 18 commits (all time) y: 413 lines of code connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java x: 9 commits (all time) y: 407 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/core/TestPurgatoryPerformance.java x: 3 commits (all time) y: 380 lines of code raft/src/main/java/org/apache/kafka/raft/FileQuorumStateStore.java x: 5 commits (all time) y: 143 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LazyIndex.java x: 6 commits (all time) y: 178 lines of code tools/src/main/java/org/apache/kafka/tools/ConsoleProducer.java x: 2 commits (all time) y: 292 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java x: 5 commits (all time) y: 456 lines of code clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java x: 70 commits (all time) y: 568 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractReadWriteDecorator.java x: 15 commits (all time) y: 254 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java x: 122 commits (all time) y: 592 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/LogicalKeyValueSegment.java x: 9 commits (all time) y: 275 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java x: 34 commits (all time) y: 164 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java x: 134 commits (all time) y: 793 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBWindowStore.java x: 54 commits (all time) y: 107 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java x: 37 commits (all time) y: 349 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java x: 41 commits (all time) y: 343 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStore.java x: 16 commits (all time) y: 616 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/Segments.java x: 21 commits (all time) y: 15 lines of code connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java x: 18 commits (all time) y: 38 lines of code committer-tools/kafka-merge-pr.py x: 2 commits (all time) y: 304 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableMapValues.java x: 32 commits (all time) y: 149 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java x: 25 commits (all time) y: 345 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/metrics/AsyncConsumerMetrics.java x: 1 commits (all time) y: 219 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/StreamStreamJoinNode.java x: 16 commits (all time) y: 118 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java x: 22 commits (all time) y: 112 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java x: 56 commits (all time) y: 353 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java x: 33 commits (all time) y: 508 lines of code streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala x: 43 commits (all time) y: 164 lines of code clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java x: 13 commits (all time) y: 669 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/ShareConsumeBenchWorker.java x: 1 commits (all time) y: 406 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamReduce.java x: 38 commits (all time) y: 133 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java x: 38 commits (all time) y: 312 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java x: 49 commits (all time) y: 171 lines of code streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala x: 24 commits (all time) y: 198 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcher.java x: 12 commits (all time) y: 305 lines of code streams/src/main/java/org/apache/kafka/streams/processor/TaskId.java x: 21 commits (all time) y: 95 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java x: 44 commits (all time) y: 286 lines of code clients/src/main/java/org/apache/kafka/clients/KafkaClient.java x: 29 commits (all time) y: 35 lines of code clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java x: 31 commits (all time) y: 263 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java x: 10 commits (all time) y: 355 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java x: 27 commits (all time) y: 1024 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java x: 40 commits (all time) y: 373 lines of code clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java x: 83 commits (all time) y: 1043 lines of code clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java x: 24 commits (all time) y: 464 lines of code clients/src/main/java/org/apache/kafka/common/record/AbstractRecords.java x: 23 commits (all time) y: 104 lines of code clients/src/main/java/org/apache/kafka/common/security/JaasContext.java x: 13 commits (all time) y: 136 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/connect/JsonConverterBenchmark.java x: 3 commits (all time) y: 389 lines of code metadata/src/main/java/org/apache/kafka/controller/BrokerHeartbeatManager.java x: 14 commits (all time) y: 307 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/TargetAssignmentBuilderBenchmark.java x: 17 commits (all time) y: 146 lines of code clients/src/main/java/org/apache/kafka/clients/admin/AdminClientConfig.java x: 34 commits (all time) y: 224 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java x: 43 commits (all time) y: 573 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/common/WorkerUtils.java x: 5 commits (all time) y: 218 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordQueue.java x: 49 commits (all time) y: 153 lines of code core/src/main/scala/kafka/server/DelayedFetch.scala x: 51 commits (all time) y: 128 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkerBase.java x: 1 commits (all time) y: 370 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/BufferPool.java x: 29 commits (all time) y: 219 lines of code clients/src/main/java/org/apache/kafka/common/network/Selector.java x: 111 commits (all time) y: 1030 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java x: 25 commits (all time) y: 14 lines of code clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java x: 47 commits (all time) y: 333 lines of code clients/src/main/java/org/apache/kafka/common/protocol/types/Schema.java x: 20 commits (all time) y: 143 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMakerConfig.java x: 20 commits (all time) y: 225 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java x: 3 commits (all time) y: 498 lines of code metadata/src/main/java/org/apache/kafka/metadata/properties/MetaProperties.java x: 2 commits (all time) y: 184 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/ByteUtilsBenchmark.java x: 6 commits (all time) y: 452 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConfig.java x: 13 commits (all time) y: 268 lines of code tools/src/main/java/org/apache/kafka/tools/LineMessageReader.java x: 1 commits (all time) y: 161 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConfig.java x: 8 commits (all time) y: 218 lines of code generator/src/main/java/org/apache/kafka/message/FieldSpec.java x: 19 commits (all time) y: 546 lines of code clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java x: 26 commits (all time) y: 401 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java x: 39 commits (all time) y: 262 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/Materialized.java x: 18 commits (all time) y: 144 lines of code clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java x: 31 commits (all time) y: 910 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java x: 21 commits (all time) y: 316 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreSegmentValueFormatter.java x: 6 commits (all time) y: 358 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContext.java x: 37 commits (all time) y: 207 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java x: 90 commits (all time) y: 154 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalProcessorContext.java x: 28 commits (all time) y: 50 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/ChangedSerializer.java x: 17 commits (all time) y: 109 lines of code clients/src/main/java/org/apache/kafka/common/security/authenticator/LoginManager.java x: 20 commits (all time) y: 188 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorTopology.java x: 28 commits (all time) y: 192 lines of code clients/src/main/java/org/apache/kafka/common/config/SaslConfigs.java x: 18 commits (all time) y: 176 lines of code clients/src/main/java/org/apache/kafka/common/network/SslChannelBuilder.java x: 30 commits (all time) y: 129 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryNavigableLRUCache.java x: 21 commits (all time) y: 122 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java x: 37 commits (all time) y: 329 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedWindowKeySchemas.java x: 4 commits (all time) y: 310 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java x: 37 commits (all time) y: 308 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java x: 10 commits (all time) y: 734 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerMetadata.java x: 9 commits (all time) y: 119 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java x: 25 commits (all time) y: 468 lines of code clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java x: 40 commits (all time) y: 302 lines of code clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java x: 22 commits (all time) y: 406 lines of code clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java x: 32 commits (all time) y: 11 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java x: 67 commits (all time) y: 446 lines of code clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java x: 40 commits (all time) y: 697 lines of code clients/src/main/java/org/apache/kafka/common/record/Record.java x: 26 commits (all time) y: 21 lines of code clients/src/main/java/org/apache/kafka/common/security/kerberos/KerberosLogin.java x: 22 commits (all time) y: 299 lines of code clients/src/main/java/org/apache/kafka/common/utils/AppInfoParser.java x: 14 commits (all time) y: 116 lines of code clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java x: 11 commits (all time) y: 416 lines of code tools/src/main/java/org/apache/kafka/tools/ManifestWorkspace.java x: 3 commits (all time) y: 455 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/assignor/ClientSideAssignorBenchmark.java x: 5 commits (all time) y: 199 lines of code tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java x: 21 commits (all time) y: 471 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java x: 20 commits (all time) y: 341 lines of code clients/src/main/java/org/apache/kafka/common/Cluster.java x: 40 commits (all time) y: 243 lines of code connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java x: 20 commits (all time) y: 254 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/StateStoreMetrics.java x: 11 commits (all time) y: 456 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/UnlimitedWindows.java x: 25 commits (all time) y: 65 lines of code clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java x: 35 commits (all time) y: 360 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerRequestCompletionHandler.scala x: 24 commits (all time) y: 141 lines of code streams/src/main/java/org/apache/kafka/streams/state/ReadOnlySessionStore.java x: 14 commits (all time) y: 79 lines of code core/src/main/scala/kafka/utils/VerifiableProperties.scala x: 25 commits (all time) y: 112 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/StreamJoined.java x: 6 commits (all time) y: 266 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java x: 18 commits (all time) y: 303 lines of code streams/src/main/java/org/apache/kafka/streams/state/Stores.java x: 61 commits (all time) y: 213 lines of code clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java x: 43 commits (all time) y: 432 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/Windows.java x: 30 commits (all time) y: 11 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/Segment.java x: 17 commits (all time) y: 8 lines of code clients/src/main/java/org/apache/kafka/common/security/ssl/SSLFactory.java x: 5 commits (all time) y: 392 lines of code clients/src/main/java/org/apache/kafka/common/network/SSLTransportLayer.java x: 6 commits (all time) y: 697 lines of code
5425.0
lines of code
  min: 1.0
  average: 112.57
  25th percentile: 16.0
  median: 46.0
  75th percentile: 110.0
  max: 5425.0
0 742.0
commits (all time)
min: 1.0 | average: 10.82 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 9.0 | max: 742.0

File Size vs. Contributors (all time): 3541 points

clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 103 contributors (all time) y: 4131 lines of code core/src/main/java/kafka/server/share/DelayedShareFetch.java x: 5 contributors (all time) y: 650 lines of code core/src/main/java/kafka/server/share/SharePartition.java x: 11 contributors (all time) y: 2060 lines of code core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 25 contributors (all time) y: 548 lines of code core/src/main/scala/kafka/server/BrokerServer.scala x: 66 contributors (all time) y: 642 lines of code core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 46 contributors (all time) y: 851 lines of code raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 47 contributors (all time) y: 3122 lines of code raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java x: 10 contributors (all time) y: 220 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java x: 6 contributors (all time) y: 93 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java x: 10 contributors (all time) y: 292 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java x: 7 contributors (all time) y: 114 lines of code raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java x: 11 contributors (all time) y: 134 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java x: 4 contributors (all time) y: 38 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java x: 2 contributors (all time) y: 156 lines of code clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateSummaryResponse.java x: 4 contributors (all time) y: 107 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 22 contributors (all time) y: 1746 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java x: 4 contributors (all time) y: 486 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java x: 2 contributors (all time) y: 70 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionFactory.java x: 3 contributors (all time) y: 31 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java x: 2 contributors (all time) y: 8 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 8 contributors (all time) y: 733 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java x: 4 contributors (all time) y: 501 lines of code core/src/main/scala/kafka/server/ForwardingManager.scala x: 10 contributors (all time) y: 146 lines of code server/src/main/java/org/apache/kafka/server/metrics/ForwardingManagerMetrics.java x: 1 contributors (all time) y: 88 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsOptions.java x: 1 contributors (all time) y: 13 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 61 contributors (all time) y: 492 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java x: 10 contributors (all time) y: 1164 lines of code server/src/main/java/org/apache/kafka/server/share/fetch/DelayedShareFetchGroupKey.java x: 1 contributors (all time) y: 39 lines of code core/src/main/java/kafka/server/share/PendingRemoteFetches.java x: 1 contributors (all time) y: 56 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java x: 5 contributors (all time) y: 186 lines of code clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 36 contributors (all time) y: 525 lines of code clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java x: 4 contributors (all time) y: 81 lines of code server/src/main/java/org/apache/kafka/server/AssignmentsManager.java x: 13 contributors (all time) y: 367 lines of code tools/src/main/java/org/apache/kafka/tools/ClusterTool.java x: 5 contributors (all time) y: 165 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 130 contributors (all time) y: 290 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 26 contributors (all time) y: 1650 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/CloseOptions.java x: 2 contributors (all time) y: 36 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java x: 7 contributors (all time) y: 854 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 47 contributors (all time) y: 557 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java x: 7 contributors (all time) y: 1748 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 26 contributors (all time) y: 5425 lines of code streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java x: 4 contributors (all time) y: 10 lines of code tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java x: 4 contributors (all time) y: 137 lines of code tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java x: 7 contributors (all time) y: 323 lines of code tools/src/main/java/org/apache/kafka/tools/TopicCommand.java x: 17 contributors (all time) y: 834 lines of code tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java x: 14 contributors (all time) y: 1054 lines of code core/src/main/java/kafka/server/TierStateMachine.java x: 9 contributors (all time) y: 169 lines of code core/src/main/scala/kafka/cluster/Partition.scala x: 92 contributors (all time) y: 1320 lines of code core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 70 contributors (all time) y: 680 lines of code metadata/src/main/java/org/apache/kafka/controller/OffsetControlManager.java x: 7 contributors (all time) y: 244 lines of code metadata/src/main/java/org/apache/kafka/controller/QuorumController.java x: 40 contributors (all time) y: 1654 lines of code metadata/src/main/java/org/apache/kafka/image/MetadataImage.java x: 9 contributors (all time) y: 144 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 20 contributors (all time) y: 719 lines of code raft/src/main/java/org/apache/kafka/raft/RaftClient.java x: 13 contributors (all time) y: 38 lines of code raft/src/main/java/org/apache/kafka/raft/RaftUtil.java x: 12 contributors (all time) y: 653 lines of code raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java x: 12 contributors (all time) y: 77 lines of code raft/src/main/java/org/apache/kafka/raft/ValidOffsetAndEpoch.java x: 4 contributors (all time) y: 52 lines of code raft/src/main/java/org/apache/kafka/snapshot/FileRawSnapshotReader.java x: 5 contributors (all time) y: 61 lines of code raft/src/main/java/org/apache/kafka/snapshot/NotifyingRawSnapshotWriter.java x: 3 contributors (all time) y: 46 lines of code raft/src/main/java/org/apache/kafka/snapshot/RawSnapshotReader.java x: 5 contributors (all time) y: 10 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java x: 11 contributors (all time) y: 207 lines of code raft/src/main/java/org/apache/kafka/snapshot/SnapshotReader.java x: 7 contributors (all time) y: 11 lines of code raft/src/main/java/org/apache/kafka/snapshot/SnapshotWriter.java x: 13 contributors (all time) y: 13 lines of code server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java x: 26 contributors (all time) y: 236 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala x: 31 contributors (all time) y: 818 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala x: 39 contributors (all time) y: 647 lines of code core/src/main/scala/kafka/server/KafkaApis.scala x: 148 contributors (all time) y: 3343 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java x: 10 contributors (all time) y: 873 lines of code core/src/main/java/kafka/server/share/SharePartitionManager.java x: 14 contributors (all time) y: 549 lines of code server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java x: 3 contributors (all time) y: 91 lines of code clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 44 contributors (all time) y: 242 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java x: 8 contributors (all time) y: 284 lines of code streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/StickyTaskAssignor.java x: 4 contributors (all time) y: 380 lines of code core/src/main/java/kafka/server/builders/KafkaApisBuilder.java x: 17 contributors (all time) y: 188 lines of code core/src/main/scala/kafka/server/AutoTopicCreationManager.scala x: 16 contributors (all time) y: 201 lines of code core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala x: 24 contributors (all time) y: 246 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java x: 5 contributors (all time) y: 121 lines of code core/src/main/scala/kafka/server/KafkaConfig.scala x: 172 contributors (all time) y: 607 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java x: 20 contributors (all time) y: 564 lines of code core/src/main/scala/kafka/network/SocketServer.scala x: 84 contributors (all time) y: 1249 lines of code core/src/main/scala/kafka/server/ControllerServer.scala x: 34 contributors (all time) y: 379 lines of code core/src/main/scala/kafka/tools/TestRaftServer.scala x: 27 contributors (all time) y: 397 lines of code core/src/main/scala/kafka/utils/CoreUtils.scala x: 30 contributors (all time) y: 116 lines of code metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistration.java x: 16 contributors (all time) y: 333 lines of code metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java x: 3 contributors (all time) y: 261 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java x: 13 contributors (all time) y: 194 lines of code server-common/src/main/java/org/apache/kafka/server/network/EndpointReadyFutures.java x: 6 contributors (all time) y: 152 lines of code tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java x: 9 contributors (all time) y: 443 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java x: 3 contributors (all time) y: 522 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java x: 3 contributors (all time) y: 298 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 77 contributors (all time) y: 1511 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/Consumer.java x: 29 contributors (all time) y: 69 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 13 contributors (all time) y: 1002 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java x: 65 contributors (all time) y: 118 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 54 contributors (all time) y: 796 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java x: 28 contributors (all time) y: 171 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java x: 33 contributors (all time) y: 206 lines of code clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 90 contributors (all time) y: 924 lines of code core/src/main/scala/kafka/coordinator/group/CoordinatorPartitionWriter.scala x: 9 contributors (all time) y: 127 lines of code core/src/main/scala/kafka/server/DelayedProduce.scala x: 19 contributors (all time) y: 88 lines of code core/src/main/scala/kafka/server/ReplicaManager.scala x: 123 contributors (all time) y: 2203 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/producer/ProducerRequestBenchmark.java x: 6 contributors (all time) y: 62 lines of code clients/src/main/java/org/apache/kafka/clients/producer/PreparedTxnState.java x: 1 contributors (all time) y: 65 lines of code tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java x: 1 contributors (all time) y: 331 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 18 contributors (all time) y: 965 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 57 contributors (all time) y: 1203 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java x: 21 contributors (all time) y: 200 lines of code core/src/main/scala/kafka/log/LogManager.scala x: 87 contributors (all time) y: 1098 lines of code core/src/main/scala/kafka/server/AbstractFetcherManager.scala x: 29 contributors (all time) y: 184 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java x: 33 contributors (all time) y: 292 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginClassLoader.java x: 5 contributors (all time) y: 76 lines of code clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 50 contributors (all time) y: 351 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 14 contributors (all time) y: 285 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteShareGroupOffsetsHandler.java x: 2 contributors (all time) y: 130 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java x: 18 contributors (all time) y: 868 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManager.java x: 3 contributors (all time) y: 1657 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java x: 8 contributors (all time) y: 599 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 11 contributors (all time) y: 754 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsCoordinatorRecordHelpers.java x: 3 contributors (all time) y: 327 lines of code streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 77 contributors (all time) y: 1397 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ReadOnlyTask.java x: 6 contributors (all time) y: 187 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java x: 58 contributors (all time) y: 1027 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/Task.java x: 17 contributors (all time) y: 103 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java x: 9 contributors (all time) y: 218 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 36 contributors (all time) y: 1727 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 37 contributors (all time) y: 858 lines of code metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java x: 5 contributors (all time) y: 145 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java x: 38 contributors (all time) y: 1033 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java x: 11 contributors (all time) y: 509 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java x: 12 contributors (all time) y: 435 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java x: 29 contributors (all time) y: 608 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorStatus.java x: 6 contributors (all time) y: 22 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java x: 12 contributors (all time) y: 422 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/TransformationChain.java x: 10 contributors (all time) y: 59 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 46 contributors (all time) y: 1718 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java x: 20 contributors (all time) y: 487 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 44 contributors (all time) y: 754 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java x: 39 contributors (all time) y: 274 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java x: 24 contributors (all time) y: 412 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 23 contributors (all time) y: 556 lines of code clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 118 contributors (all time) y: 831 lines of code clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java x: 41 contributors (all time) y: 431 lines of code clients/src/main/java/org/apache/kafka/clients/producer/Producer.java x: 16 contributors (all time) y: 36 lines of code clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 73 contributors (all time) y: 528 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 33 contributors (all time) y: 1385 lines of code clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java x: 8 contributors (all time) y: 130 lines of code core/src/main/java/kafka/server/share/ShareFetchUtils.java x: 8 contributors (all time) y: 175 lines of code server/src/main/java/org/apache/kafka/server/share/fetch/ShareFetch.java x: 2 contributors (all time) y: 117 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Readable.java x: 11 contributors (all time) y: 51 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 43 contributors (all time) y: 262 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddOffsetsToTxnResponse.java x: 10 contributors (all time) y: 40 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnResponse.java x: 12 contributors (all time) y: 106 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java x: 8 contributors (all time) y: 85 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsResponse.java x: 8 contributors (all time) y: 46 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterPartitionResponse.java x: 5 contributors (all time) y: 38 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterReplicaLogDirsResponse.java x: 8 contributors (all time) y: 41 lines of code clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochResponse.java x: 7 contributors (all time) y: 40 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateAclsResponse.java x: 9 contributors (all time) y: 40 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateDelegationTokenResponse.java x: 9 contributors (all time) y: 75 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java x: 14 contributors (all time) y: 41 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteAclsResponse.java x: 11 contributors (all time) y: 110 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeAclsResponse.java x: 12 contributors (all time) y: 128 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeClientQuotasResponse.java x: 8 contributors (all time) y: 88 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeGroupsResponse.java x: 17 contributors (all time) y: 112 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeLogDirsResponse.java x: 14 contributors (all time) y: 44 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeProducersResponse.java x: 2 contributors (all time) y: 46 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeQuorumResponse.java x: 7 contributors (all time) y: 67 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java x: 3 contributors (all time) y: 68 lines of code clients/src/main/java/org/apache/kafka/common/requests/EndTxnResponse.java x: 9 contributors (all time) y: 43 lines of code clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java x: 30 contributors (all time) y: 195 lines of code clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorResponse.java x: 14 contributors (all time) y: 137 lines of code clients/src/main/java/org/apache/kafka/common/requests/InitProducerIdResponse.java x: 7 contributors (all time) y: 43 lines of code clients/src/main/java/org/apache/kafka/common/requests/InitializeShareGroupStateResponse.java x: 4 contributors (all time) y: 96 lines of code clients/src/main/java/org/apache/kafka/common/requests/JoinGroupResponse.java x: 19 contributors (all time) y: 52 lines of code clients/src/main/java/org/apache/kafka/common/requests/ListGroupsResponse.java x: 12 contributors (all time) y: 36 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitResponse.java x: 19 contributors (all time) y: 206 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java x: 22 contributors (all time) y: 307 lines of code clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitResponse.java x: 13 contributors (all time) y: 138 lines of code clients/src/main/java/org/apache/kafka/common/requests/WriteTxnMarkersResponse.java x: 10 contributors (all time) y: 84 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java x: 2 contributors (all time) y: 829 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareGroupOffset.java x: 2 contributors (all time) y: 200 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java x: 7 contributors (all time) y: 160 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetCommitRequest.java x: 19 contributors (all time) y: 109 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java x: 12 contributors (all time) y: 757 lines of code metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java x: 15 contributors (all time) y: 591 lines of code metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java x: 17 contributors (all time) y: 376 lines of code raft/src/main/java/org/apache/kafka/raft/LeaderState.java x: 19 contributors (all time) y: 874 lines of code raft/src/main/java/org/apache/kafka/raft/VoterSet.java x: 4 contributors (all time) y: 281 lines of code raft/src/main/java/org/apache/kafka/raft/internals/UpdateVoterHandler.java x: 5 contributors (all time) y: 242 lines of code server-common/src/main/java/org/apache/kafka/server/common/KRaftVersion.java x: 6 contributors (all time) y: 83 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java x: 4 contributors (all time) y: 1156 lines of code release/release.py x: 6 contributors (all time) y: 237 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java x: 2 contributors (all time) y: 359 lines of code core/src/main/scala/kafka/raft/RaftManager.scala x: 30 contributors (all time) y: 244 lines of code core/src/main/scala/kafka/admin/ConfigCommand.scala x: 57 contributors (all time) y: 582 lines of code core/src/main/scala/kafka/server/DynamicConfig.scala x: 22 contributors (all time) y: 32 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java x: 14 contributors (all time) y: 513 lines of code clients/src/main/java/org/apache/kafka/common/serialization/Deserializer.java x: 12 contributors (all time) y: 20 lines of code clients/src/main/java/org/apache/kafka/common/serialization/Serializer.java x: 10 contributors (all time) y: 15 lines of code core/src/main/scala/kafka/server/FetchSession.scala x: 22 contributors (all time) y: 580 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 71 contributors (all time) y: 574 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java x: 10 contributors (all time) y: 335 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchCollector.java x: 7 contributors (all time) y: 271 lines of code clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java x: 28 contributors (all time) y: 164 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java x: 7 contributors (all time) y: 86 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java x: 15 contributors (all time) y: 219 lines of code server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java x: 13 contributors (all time) y: 58 lines of code core/src/main/scala/kafka/server/KafkaBroker.scala x: 18 contributors (all time) y: 82 lines of code metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java x: 25 contributors (all time) y: 650 lines of code clients/src/main/java/org/apache/kafka/common/errors/GroupMaxSizeReachedException.java x: 3 contributors (all time) y: 7 lines of code clients/src/main/java/org/apache/kafka/common/requests/JoinGroupRequest.java x: 24 contributors (all time) y: 101 lines of code coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 10 contributors (all time) y: 1472 lines of code core/src/main/scala/kafka/server/AddPartitionsToTxnManager.scala x: 11 contributors (all time) y: 243 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java x: 13 contributors (all time) y: 74 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java x: 11 contributors (all time) y: 172 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java x: 14 contributors (all time) y: 806 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroup.java x: 7 contributors (all time) y: 186 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java x: 3 contributors (all time) y: 623 lines of code clients/src/main/java/org/apache/kafka/server/authorizer/Authorizer.java x: 6 contributors (all time) y: 121 lines of code core/src/main/java/kafka/server/QuotaFactory.java x: 3 contributors (all time) y: 141 lines of code core/src/main/scala/kafka/server/ControllerApis.scala x: 30 contributors (all time) y: 975 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java x: 16 contributors (all time) y: 268 lines of code tools/src/main/java/org/apache/kafka/tools/PushHttpMetricsReporter.java x: 8 contributors (all time) y: 255 lines of code core/src/main/scala/kafka/server/ConfigHandler.scala x: 39 contributors (all time) y: 122 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Herder.java x: 17 contributors (all time) y: 74 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SubmittedRecords.java x: 3 contributors (all time) y: 158 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 56 contributors (all time) y: 2304 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java x: 12 contributors (all time) y: 729 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java x: 27 contributors (all time) y: 494 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/DeadLetterQueueReporter.java x: 10 contributors (all time) y: 155 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java x: 11 contributors (all time) y: 215 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java x: 17 contributors (all time) y: 197 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java x: 16 contributors (all time) y: 393 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/Plugins.java x: 18 contributors (all time) y: 501 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestClient.java x: 16 contributors (all time) y: 158 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorPluginsResource.java x: 16 contributors (all time) y: 137 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java x: 24 contributors (all time) y: 345 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java x: 30 contributors (all time) y: 503 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java x: 5 contributors (all time) y: 315 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java x: 27 contributors (all time) y: 868 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java x: 20 contributors (all time) y: 287 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/MemoryConfigBackingStore.java x: 13 contributors (all time) y: 160 lines of code server-common/src/main/java/org/apache/kafka/queue/KafkaEventQueue.java x: 9 contributors (all time) y: 383 lines of code core/src/main/scala/kafka/network/RequestChannel.scala x: 60 contributors (all time) y: 372 lines of code core/src/main/scala/kafka/server/KafkaRequestHandler.scala x: 40 contributors (all time) y: 168 lines of code config/log4j2.yaml x: 3 contributors (all time) y: 112 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java x: 1 contributors (all time) y: 462 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleanerManager.java x: 1 contributors (all time) y: 502 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java x: 18 contributors (all time) y: 540 lines of code tools/src/main/java/org/apache/kafka/tools/GroupsCommand.java x: 3 contributors (all time) y: 241 lines of code core/src/main/scala/kafka/server/ControllerMutationQuotaManager.scala x: 4 contributors (all time) y: 151 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java x: 55 contributors (all time) y: 731 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManagers.java x: 14 contributors (all time) y: 329 lines of code clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java x: 36 contributors (all time) y: 382 lines of code server/src/main/java/org/apache/kafka/server/share/context/ShareSessionContext.java x: 4 contributors (all time) y: 173 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java x: 7 contributors (all time) y: 280 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java x: 28 contributors (all time) y: 444 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java x: 13 contributors (all time) y: 561 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 90 contributors (all time) y: 1371 lines of code core/src/main/scala/kafka/server/ClientQuotaManager.scala x: 35 contributors (all time) y: 405 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/CheckpointBench.java x: 24 contributors (all time) y: 139 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/server/PartitionCreationBench.java x: 22 contributors (all time) y: 175 lines of code core/src/main/java/kafka/server/builders/LogManagerBuilder.java x: 18 contributors (all time) y: 135 lines of code core/src/main/java/kafka/server/builders/ReplicaManagerBuilder.java x: 21 contributors (all time) y: 101 lines of code core/src/main/java/kafka/server/handlers/DescribeTopicPartitionsRequestHandler.java x: 5 contributors (all time) y: 97 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 5 contributors (all time) y: 1114 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LocalLog.java x: 5 contributors (all time) y: 666 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java x: 55 contributors (all time) y: 1170 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java x: 6 contributors (all time) y: 756 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManager.java x: 5 contributors (all time) y: 218 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerMembershipManager.java x: 2 contributors (all time) y: 270 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerGroupMember.java x: 32 contributors (all time) y: 174 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/ConsumerTask.java x: 11 contributors (all time) y: 350 lines of code server-common/src/main/java/org/apache/kafka/server/util/InterBrokerSendThread.java x: 5 contributors (all time) y: 202 lines of code storage/src/main/java/org/apache/kafka/server/purgatory/DelayedRemoteListOffsets.java x: 1 contributors (all time) y: 146 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ActiveTaskCreator.java x: 12 contributors (all time) y: 236 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java x: 14 contributors (all time) y: 442 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java x: 17 contributors (all time) y: 414 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegments.java x: 6 contributors (all time) y: 135 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogValidator.java x: 12 contributors (all time) y: 460 lines of code storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicMetrics.java x: 5 contributors (all time) y: 327 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/ForeachAction.java x: 8 contributors (all time) y: 5 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerSupplier.java x: 9 contributors (all time) y: 8 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/ValueTransformerWithKeySupplier.java x: 6 contributors (all time) y: 7 lines of code raft/src/main/java/org/apache/kafka/raft/ElectionState.java x: 8 contributors (all time) y: 152 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumConfig.java x: 7 contributors (all time) y: 233 lines of code raft/src/main/java/org/apache/kafka/raft/internals/BatchAccumulator.java x: 19 contributors (all time) y: 451 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStreamThread.java x: 22 contributors (all time) y: 354 lines of code core/src/main/scala/kafka/server/ReplicaFetcherManager.scala x: 19 contributors (all time) y: 37 lines of code core/src/main/scala/kafka/server/ReplicaFetcherThread.scala x: 72 contributors (all time) y: 120 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/InternalTopicManager.java x: 2 contributors (all time) y: 235 lines of code clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java x: 50 contributors (all time) y: 284 lines of code metadata/src/main/java/org/apache/kafka/controller/QuorumFeatures.java x: 11 contributors (all time) y: 101 lines of code metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 35 contributors (all time) y: 1975 lines of code metadata/src/main/java/org/apache/kafka/metadata/PartitionRegistration.java x: 15 contributors (all time) y: 404 lines of code gradle/spotbugs-exclude.xml x: 38 contributors (all time) y: 339 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TargetAssignmentBuilder.java x: 8 contributors (all time) y: 316 lines of code clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java x: 25 contributors (all time) y: 567 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java x: 41 contributors (all time) y: 285 lines of code clients/src/main/java/org/apache/kafka/common/requests/AddPartitionsToTxnRequest.java x: 11 contributors (all time) y: 154 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterConfigsRequest.java x: 9 contributors (all time) y: 97 lines of code clients/src/main/java/org/apache/kafka/common/requests/ApiVersionsRequest.java x: 14 contributors (all time) y: 85 lines of code clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsRequest.java x: 15 contributors (all time) y: 81 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteTopicsRequest.java x: 15 contributors (all time) y: 86 lines of code clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersRequest.java x: 8 contributors (all time) y: 111 lines of code clients/src/main/java/org/apache/kafka/common/requests/FindCoordinatorRequest.java x: 10 contributors (all time) y: 102 lines of code clients/src/main/java/org/apache/kafka/common/requests/HeartbeatRequest.java x: 16 contributors (all time) y: 49 lines of code clients/src/main/java/org/apache/kafka/common/requests/LeaveGroupRequest.java x: 13 contributors (all time) y: 89 lines of code clients/src/main/java/org/apache/kafka/common/requests/MetadataRequest.java x: 21 contributors (all time) y: 158 lines of code clients/src/main/java/org/apache/kafka/common/requests/SyncGroupRequest.java x: 12 contributors (all time) y: 63 lines of code clients/src/main/java/org/apache/kafka/common/requests/TxnOffsetCommitRequest.java x: 13 contributors (all time) y: 214 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/SubscriptionInfo.java x: 19 contributors (all time) y: 309 lines of code server-common/src/main/java/org/apache/kafka/server/common/CheckpointFile.java x: 7 contributors (all time) y: 137 lines of code tools/src/main/java/org/apache/kafka/tools/ClientMetricsCommand.java x: 6 contributors (all time) y: 296 lines of code metadata/src/main/java/org/apache/kafka/metadata/storage/Formatter.java x: 10 contributors (all time) y: 390 lines of code clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java x: 45 contributors (all time) y: 420 lines of code core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala x: 26 contributors (all time) y: 379 lines of code tools/src/main/java/org/apache/kafka/tools/AclCommand.java x: 2 contributors (all time) y: 531 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeStreamsGroupsHandler.java x: 2 contributors (all time) y: 233 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionMetadata.scala x: 15 contributors (all time) y: 418 lines of code generator/src/main/java/org/apache/kafka/message/checker/FieldSpecPairIterator.java x: 2 contributors (all time) y: 89 lines of code core/src/main/scala/kafka/cluster/Replica.scala x: 24 contributors (all time) y: 119 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala x: 27 contributors (all time) y: 368 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java x: 23 contributors (all time) y: 133 lines of code metadata/src/main/java/org/apache/kafka/controller/ClientQuotaControlManager.java x: 10 contributors (all time) y: 265 lines of code metadata/src/main/java/org/apache/kafka/image/TopicsDelta.java x: 13 contributors (all time) y: 174 lines of code metadata/src/main/java/org/apache/kafka/metadata/KafkaConfigSchema.java x: 7 contributors (all time) y: 209 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizerData.java x: 10 contributors (all time) y: 427 lines of code metadata/src/main/java/org/apache/kafka/metadata/placement/StripedReplicaPlacer.java x: 6 contributors (all time) y: 213 lines of code metadata/src/main/java/org/apache/kafka/metadata/properties/MetaPropertiesEnsemble.java x: 7 contributors (all time) y: 396 lines of code server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java x: 7 contributors (all time) y: 490 lines of code clients/src/main/java/org/apache/kafka/common/utils/LogContext.java x: 5 contributors (all time) y: 636 lines of code core/src/main/scala/kafka/server/LocalLeaderEndPoint.scala x: 10 contributors (all time) y: 182 lines of code core/src/main/scala/kafka/server/ReplicaAlterLogDirsThread.scala x: 27 contributors (all time) y: 156 lines of code core/src/main/scala/kafka/tools/DumpLogSegments.scala x: 55 contributors (all time) y: 566 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java x: 17 contributors (all time) y: 548 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogLoader.java x: 5 contributors (all time) y: 374 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java x: 8 contributors (all time) y: 955 lines of code tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java x: 2 contributors (all time) y: 384 lines of code metadata/src/main/java/org/apache/kafka/controller/PeriodicTaskControlManager.java x: 3 contributors (all time) y: 171 lines of code clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupDescription.java x: 1 contributors (all time) y: 116 lines of code clients/src/main/java/org/apache/kafka/clients/admin/StreamsGroupMemberDescription.java x: 1 contributors (all time) y: 252 lines of code tools/src/main/java/org/apache/kafka/tools/VerifiableShareConsumer.java x: 1 contributors (all time) y: 514 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/Graph.java x: 2 contributors (all time) y: 406 lines of code clients/src/main/java/org/apache/kafka/common/config/internals/BrokerSecurityConfigs.java x: 14 contributors (all time) y: 158 lines of code clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java x: 34 contributors (all time) y: 639 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java x: 38 contributors (all time) y: 1174 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/ModernGroup.java x: 6 contributors (all time) y: 274 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateUpdateTask.java x: 17 contributors (all time) y: 135 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/UniformHeterogeneousAssignmentBuilder.java x: 6 contributors (all time) y: 385 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetrics.java x: 8 contributors (all time) y: 475 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroupMember.java x: 5 contributors (all time) y: 393 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupMember.java x: 3 contributors (all time) y: 218 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ConfigEntry.java x: 15 contributors (all time) y: 167 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 35 contributors (all time) y: 1257 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfiguration.java x: 20 contributors (all time) y: 166 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsBuilder.java x: 31 contributors (all time) y: 176 lines of code streams/src/main/java/org/apache/kafka/streams/TopologyConfig.java x: 12 contributors (all time) y: 284 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/CogroupedStreamAggregateBuilder.java x: 16 contributors (all time) y: 242 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/InternalStreamsBuilder.java x: 29 contributors (all time) y: 536 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java x: 49 contributors (all time) y: 1118 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 47 contributors (all time) y: 1852 lines of code clients/src/main/java/org/apache/kafka/common/record/Records.java x: 14 contributors (all time) y: 19 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java x: 8 contributors (all time) y: 326 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/SinkNode.java x: 22 contributors (all time) y: 83 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/SourceNode.java x: 19 contributors (all time) y: 71 lines of code clients/src/main/java/org/apache/kafka/clients/ClientUtils.java x: 26 contributors (all time) y: 224 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/TopicIds.java x: 4 contributors (all time) y: 220 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KGroupedTableImpl.java x: 20 contributors (all time) y: 184 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryTimeOrderedKeyValueChangeBuffer.java x: 3 contributors (all time) y: 431 lines of code core/src/main/scala/kafka/server/AlterPartitionManager.scala x: 14 contributors (all time) y: 215 lines of code core/src/main/scala/kafka/tools/StorageTool.scala x: 21 contributors (all time) y: 401 lines of code metadata/src/main/java/org/apache/kafka/image/loader/MetadataLoader.java x: 11 contributors (all time) y: 414 lines of code tools/src/main/java/org/apache/kafka/tools/FeatureCommand.java x: 9 contributors (all time) y: 398 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedCogroupedKStream.java x: 15 contributors (all time) y: 19 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindowedKStream.java x: 20 contributors (all time) y: 38 lines of code server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java x: 6 contributors (all time) y: 794 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java x: 26 contributors (all time) y: 789 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/KGroupedStream.java x: 27 contributors (all time) y: 37 lines of code streams/src/main/java/org/apache/kafka/streams/Topology.java x: 18 contributors (all time) y: 449 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java x: 49 contributors (all time) y: 183 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetrics.java x: 15 contributors (all time) y: 267 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/RestServer.java x: 29 contributors (all time) y: 403 lines of code clients/src/main/java/org/apache/kafka/common/config/SslConfigs.java x: 20 contributors (all time) y: 122 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/Acknowledgements.java x: 1 contributors (all time) y: 167 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareCompletedFetch.java x: 2 contributors (all time) y: 307 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java x: 33 contributors (all time) y: 459 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredSessionStore.java x: 26 contributors (all time) y: 444 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredWindowStore.java x: 32 contributors (all time) y: 458 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNode.java x: 15 contributors (all time) y: 125 lines of code core/src/main/scala/kafka/server/ConfigAdminManager.scala x: 9 contributors (all time) y: 322 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/SubscriptionState.java x: 42 contributors (all time) y: 954 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java x: 9 contributors (all time) y: 188 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/TargetAssignmentBuilder.java x: 1 contributors (all time) y: 187 lines of code streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java x: 17 contributors (all time) y: 42 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/AbstractRocksDBSegmentedBytesStore.java x: 19 contributors (all time) y: 327 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStore.java x: 14 contributors (all time) y: 95 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java x: 23 contributors (all time) y: 609 lines of code core/src/main/scala/kafka/server/ControllerConfigurationValidator.scala x: 16 contributors (all time) y: 105 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalProcessorContextImpl.java x: 16 contributors (all time) y: 114 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java x: 21 contributors (all time) y: 215 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/CachingKeyValueStore.java x: 22 contributors (all time) y: 430 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/CachingSessionStore.java x: 19 contributors (all time) y: 410 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/CachingWindowStore.java x: 30 contributors (all time) y: 473 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/ChangeLoggingSessionBytesStore.java x: 11 contributors (all time) y: 77 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/TimeOrderedCachingWindowStore.java x: 5 contributors (all time) y: 572 lines of code storage/src/main/java/org/apache/kafka/storage/log/metrics/BrokerTopicStats.java x: 3 contributors (all time) y: 196 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java x: 18 contributors (all time) y: 829 lines of code clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java x: 23 contributors (all time) y: 321 lines of code clients/src/main/java/org/apache/kafka/common/security/JaasUtils.java x: 11 contributors (all time) y: 9 lines of code clients/src/main/java/org/apache/kafka/clients/NetworkClient.java x: 60 contributors (all time) y: 1124 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ForwardingDisabledProcessorContext.java x: 10 contributors (all time) y: 113 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java x: 29 contributors (all time) y: 473 lines of code tools/src/main/java/org/apache/kafka/tools/VerifiableConsumer.java x: 23 contributors (all time) y: 547 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java x: 14 contributors (all time) y: 596 lines of code tools/src/main/java/org/apache/kafka/tools/StreamsResetter.java x: 10 contributors (all time) y: 612 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommandOptions.java x: 9 contributors (all time) y: 244 lines of code core/src/main/scala/kafka/server/NodeToControllerChannelManager.scala x: 12 contributors (all time) y: 273 lines of code clients/src/main/java/org/apache/kafka/common/network/SaslChannelBuilder.java x: 21 contributors (all time) y: 345 lines of code clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java x: 22 contributors (all time) y: 530 lines of code generator/src/main/java/org/apache/kafka/message/CoordinatorRecordTypeGenerator.java x: 1 contributors (all time) y: 220 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java x: 9 contributors (all time) y: 199 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java x: 11 contributors (all time) y: 1435 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetricsRecorder.java x: 8 contributors (all time) y: 459 lines of code core/src/main/scala/kafka/Kafka.scala x: 32 contributors (all time) y: 75 lines of code clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java x: 22 contributors (all time) y: 239 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java x: 17 contributors (all time) y: 327 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java x: 23 contributors (all time) y: 597 lines of code generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java x: 19 contributors (all time) y: 1611 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamKStreamJoin.java x: 25 contributors (all time) y: 218 lines of code streams/src/main/java/org/apache/kafka/streams/processor/assignment/TaskAssignmentUtils.java x: 4 contributors (all time) y: 780 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java x: 28 contributors (all time) y: 738 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/RepartitionTopics.java x: 8 contributors (all time) y: 226 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/StoreQueryUtils.java x: 7 contributors (all time) y: 446 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api/MockProcessorContext.java x: 9 contributors (all time) y: 346 lines of code tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java x: 7 contributors (all time) y: 602 lines of code tools/src/main/java/org/apache/kafka/tools/ProducerPerformance.java x: 33 contributors (all time) y: 441 lines of code connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java x: 32 contributors (all time) y: 623 lines of code connect/transforms/src/main/java/org/apache/kafka/connect/transforms/Cast.java x: 18 contributors (all time) y: 413 lines of code connect/transforms/src/main/java/org/apache/kafka/connect/transforms/TimestampConverter.java x: 8 contributors (all time) y: 407 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/core/TestPurgatoryPerformance.java x: 3 contributors (all time) y: 380 lines of code server-common/src/main/java/org/apache/kafka/timeline/TimelineHashSet.java x: 4 contributors (all time) y: 195 lines of code tools/src/main/java/org/apache/kafka/tools/ConsoleProducer.java x: 2 contributors (all time) y: 292 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/CoordinatorClient.java x: 5 contributors (all time) y: 456 lines of code clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java x: 21 contributors (all time) y: 568 lines of code streams/src/main/java/org/apache/kafka/streams/processor/StateStore.java x: 11 contributors (all time) y: 31 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorStateManager.java x: 35 contributors (all time) y: 592 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MemoryLRUCache.java x: 17 contributors (all time) y: 164 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBSessionStore.java x: 13 contributors (all time) y: 119 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java x: 43 contributors (all time) y: 793 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/util/KafkaBasedLog.java x: 27 contributors (all time) y: 349 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java x: 16 contributors (all time) y: 343 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStore.java x: 5 contributors (all time) y: 616 lines of code connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java x: 15 contributors (all time) y: 38 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java x: 14 contributors (all time) y: 345 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableJoinMerger.java x: 14 contributors (all time) y: 112 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConfig.java x: 35 contributors (all time) y: 353 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TopologyMetadata.java x: 13 contributors (all time) y: 508 lines of code streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KStream.scala x: 26 contributors (all time) y: 164 lines of code clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java x: 7 contributors (all time) y: 669 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/agent/AgentClient.java x: 4 contributors (all time) y: 269 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/ShareConsumeBenchWorker.java x: 1 contributors (all time) y: 406 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamAggregate.java x: 21 contributors (all time) y: 138 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSessionWindowAggregate.java x: 15 contributors (all time) y: 312 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamSlidingWindowAggregate.java x: 11 contributors (all time) y: 404 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamWindowAggregate.java x: 19 contributors (all time) y: 171 lines of code streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/kstream/KTable.scala x: 18 contributors (all time) y: 198 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcher.java x: 10 contributors (all time) y: 305 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java x: 15 contributors (all time) y: 286 lines of code clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java x: 24 contributors (all time) y: 263 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java x: 7 contributors (all time) y: 355 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java x: 16 contributors (all time) y: 1024 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java x: 16 contributors (all time) y: 373 lines of code clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java x: 53 contributors (all time) y: 1043 lines of code clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java x: 14 contributors (all time) y: 464 lines of code clients/src/main/java/org/apache/kafka/common/security/ssl/CommonNameLoggingTrustManagerFactoryWrapper.java x: 4 contributors (all time) y: 302 lines of code raft/src/main/java/org/apache/kafka/raft/internals/AddVoterHandler.java x: 5 contributors (all time) y: 268 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/connect/JsonConverterBenchmark.java x: 3 contributors (all time) y: 389 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java x: 31 contributors (all time) y: 573 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/RoundTripWorkerBase.java x: 1 contributors (all time) y: 370 lines of code clients/src/main/java/org/apache/kafka/common/network/Selector.java x: 55 contributors (all time) y: 1030 lines of code clients/src/main/java/org/apache/kafka/common/metrics/Metrics.java x: 35 contributors (all time) y: 333 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/agent/WorkerManager.java x: 3 contributors (all time) y: 498 lines of code clients/src/main/java/org/apache/kafka/common/internals/KafkaFutureImpl.java x: 12 contributors (all time) y: 162 lines of code metadata/src/main/java/org/apache/kafka/metadata/properties/MetaProperties.java x: 2 contributors (all time) y: 184 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/ByteUtilsBenchmark.java x: 6 contributors (all time) y: 452 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConfig.java x: 8 contributors (all time) y: 268 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java x: 15 contributors (all time) y: 248 lines of code connect/transforms/src/main/java/org/apache/kafka/connect/transforms/ReplaceField.java x: 12 contributors (all time) y: 184 lines of code generator/src/main/java/org/apache/kafka/message/FieldSpec.java x: 11 contributors (all time) y: 546 lines of code clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java x: 14 contributors (all time) y: 401 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/Tasks.java x: 11 contributors (all time) y: 262 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/TimeWindows.java x: 18 contributors (all time) y: 91 lines of code clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java x: 23 contributors (all time) y: 910 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryKeyValueStore.java x: 20 contributors (all time) y: 237 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredTimestampedKeyValueStore.java x: 13 contributors (all time) y: 316 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBVersionedStoreSegmentValueFormatter.java x: 4 contributors (all time) y: 358 lines of code tools/src/main/java/org/apache/kafka/tools/VerifiableProducer.java x: 26 contributors (all time) y: 390 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractTask.java x: 22 contributors (all time) y: 154 lines of code clients/src/main/java/org/apache/kafka/common/record/CompressionType.java x: 19 contributors (all time) y: 133 lines of code server-common/src/main/java/org/apache/kafka/timeline/SnapshottableHashTable.java x: 5 contributors (all time) y: 280 lines of code clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java x: 20 contributors (all time) y: 392 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectDistributed.java x: 20 contributors (all time) y: 71 lines of code clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java x: 13 contributors (all time) y: 482 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableKTableLeftJoin.java x: 15 contributors (all time) y: 148 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java x: 18 contributors (all time) y: 433 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/NamedCache.java x: 20 contributors (all time) y: 329 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/PrefixedWindowKeySchemas.java x: 3 contributors (all time) y: 310 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/SessionKeySchema.java x: 12 contributors (all time) y: 146 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/metrics/RocksDBMetrics.java x: 3 contributors (all time) y: 734 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/util/TopicAdmin.java x: 17 contributors (all time) y: 468 lines of code clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java x: 29 contributors (all time) y: 302 lines of code clients/src/main/java/org/apache/kafka/clients/admin/AdminClient.java x: 17 contributors (all time) y: 11 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java x: 25 contributors (all time) y: 446 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java x: 14 contributors (all time) y: 172 lines of code clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java x: 15 contributors (all time) y: 51 lines of code clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java x: 18 contributors (all time) y: 697 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/SustainedConnectionWorker.java x: 4 contributors (all time) y: 395 lines of code clients/src/main/java/org/apache/kafka/common/serialization/Serdes.java x: 12 contributors (all time) y: 194 lines of code clients/src/main/java/org/apache/kafka/common/utils/ImplicitLinkedHashCollection.java x: 7 contributors (all time) y: 416 lines of code tools/src/main/java/org/apache/kafka/tools/ManifestWorkspace.java x: 3 contributors (all time) y: 455 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/TaskManager.java x: 5 contributors (all time) y: 484 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/workload/ConsumeBenchWorker.java x: 4 contributors (all time) y: 466 lines of code trogdor/src/main/java/org/apache/kafka/trogdor/coordinator/NodeManager.java x: 4 contributors (all time) y: 237 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/OffsetSyncStore.java x: 6 contributors (all time) y: 214 lines of code tools/src/main/java/org/apache/kafka/tools/ClientCompatibilityTest.java x: 14 contributors (all time) y: 471 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionalMessageCopier.java x: 11 contributors (all time) y: 341 lines of code clients/src/main/java/org/apache/kafka/common/Cluster.java x: 21 contributors (all time) y: 243 lines of code clients/src/main/java/org/apache/kafka/common/network/PlaintextChannelBuilder.java x: 16 contributors (all time) y: 80 lines of code connect/api/src/main/java/org/apache/kafka/connect/data/ConnectSchema.java x: 18 contributors (all time) y: 254 lines of code generator/src/main/java/org/apache/kafka/message/SchemaGenerator.java x: 11 contributors (all time) y: 283 lines of code clients/src/main/java/org/apache/kafka/common/network/KafkaChannel.java x: 18 contributors (all time) y: 360 lines of code core/src/main/scala/kafka/utils/VerifiableProperties.scala x: 18 contributors (all time) y: 112 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/TaskMetrics.java x: 7 contributors (all time) y: 303 lines of code streams/src/main/java/org/apache/kafka/streams/state/Stores.java x: 24 contributors (all time) y: 213 lines of code clients/src/main/java/org/apache/kafka/common/protocol/types/Struct.java x: 24 contributors (all time) y: 432 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/AssignmentInfo.java x: 16 contributors (all time) y: 417 lines of code clients/src/main/java/org/apache/kafka/common/network/SSLTransportLayer.java x: 4 contributors (all time) y: 697 lines of code
5425.0
lines of code
  min: 1.0
  average: 112.57
  25th percentile: 16.0
  median: 46.0
  75th percentile: 110.0
  max: 5425.0
0 172.0
contributors (all time)
min: 1.0 | average: 6.14 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 7.0 | max: 172.0

File Size vs. Commits (30 days): 471 points

clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 8 commits (30d) y: 4131 lines of code core/src/main/java/kafka/server/share/DelayedShareFetch.java x: 3 commits (30d) y: 650 lines of code core/src/main/java/kafka/server/share/SharePartition.java x: 5 commits (30d) y: 2060 lines of code core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 4 commits (30d) y: 548 lines of code core/src/main/scala/kafka/server/BrokerServer.scala x: 14 commits (30d) y: 642 lines of code core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 5 commits (30d) y: 851 lines of code raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 4 commits (30d) y: 3122 lines of code raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java x: 1 commits (30d) y: 220 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java x: 1 commits (30d) y: 93 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java x: 1 commits (30d) y: 292 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java x: 2 commits (30d) y: 114 lines of code raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java x: 2 commits (30d) y: 134 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java x: 1 commits (30d) y: 38 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java x: 2 commits (30d) y: 156 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 10 commits (30d) y: 1746 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java x: 1 commits (30d) y: 486 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java x: 1 commits (30d) y: 70 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java x: 1 commits (30d) y: 8 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 4 commits (30d) y: 733 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java x: 3 commits (30d) y: 501 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 2 commits (30d) y: 492 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java x: 2 commits (30d) y: 1164 lines of code core/src/main/java/kafka/server/share/PendingRemoteFetches.java x: 1 commits (30d) y: 56 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java x: 1 commits (30d) y: 186 lines of code clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 1 commits (30d) y: 525 lines of code server/src/main/java/org/apache/kafka/server/AssignmentsManager.java x: 1 commits (30d) y: 367 lines of code tools/src/main/java/org/apache/kafka/tools/ClusterTool.java x: 1 commits (30d) y: 165 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 3 commits (30d) y: 290 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 5 commits (30d) y: 1650 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java x: 2 commits (30d) y: 854 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 3 commits (30d) y: 557 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java x: 1 commits (30d) y: 1748 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 17 commits (30d) y: 5425 lines of code tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java x: 1 commits (30d) y: 137 lines of code tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java x: 1 commits (30d) y: 323 lines of code tools/src/main/java/org/apache/kafka/tools/TopicCommand.java x: 1 commits (30d) y: 834 lines of code tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java x: 2 commits (30d) y: 1054 lines of code core/src/main/scala/kafka/cluster/Partition.scala x: 4 commits (30d) y: 1320 lines of code core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 2 commits (30d) y: 680 lines of code metadata/src/main/java/org/apache/kafka/controller/OffsetControlManager.java x: 1 commits (30d) y: 244 lines of code metadata/src/main/java/org/apache/kafka/controller/QuorumController.java x: 2 commits (30d) y: 1654 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 2 commits (30d) y: 719 lines of code raft/src/main/java/org/apache/kafka/raft/RaftClient.java x: 2 commits (30d) y: 38 lines of code raft/src/main/java/org/apache/kafka/raft/RaftUtil.java x: 1 commits (30d) y: 653 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java x: 1 commits (30d) y: 207 lines of code server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java x: 3 commits (30d) y: 236 lines of code server-common/src/main/java/org/apache/kafka/server/common/ShareVersion.java x: 2 commits (30d) y: 49 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala x: 2 commits (30d) y: 818 lines of code core/src/main/scala/kafka/server/KafkaApis.scala x: 16 commits (30d) y: 3343 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java x: 1 commits (30d) y: 873 lines of code core/src/main/java/kafka/server/share/SharePartitionManager.java x: 3 commits (30d) y: 549 lines of code server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java x: 2 commits (30d) y: 91 lines of code core/src/main/java/kafka/server/builders/KafkaApisBuilder.java x: 5 commits (30d) y: 188 lines of code core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala x: 2 commits (30d) y: 246 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java x: 3 commits (30d) y: 121 lines of code core/src/main/scala/kafka/server/KafkaConfig.scala x: 9 commits (30d) y: 607 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java x: 4 commits (30d) y: 564 lines of code server-common/src/main/java/org/apache/kafka/server/common/Feature.java x: 2 commits (30d) y: 186 lines of code core/src/main/scala/kafka/network/SocketServer.scala x: 3 commits (30d) y: 1249 lines of code core/src/main/scala/kafka/server/ControllerServer.scala x: 6 commits (30d) y: 379 lines of code core/src/main/scala/kafka/tools/TestRaftServer.scala x: 3 commits (30d) y: 397 lines of code core/src/main/scala/kafka/utils/CoreUtils.scala x: 1 commits (30d) y: 116 lines of code metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistration.java x: 2 commits (30d) y: 333 lines of code metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java x: 1 commits (30d) y: 261 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java x: 3 commits (30d) y: 194 lines of code tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java x: 2 commits (30d) y: 443 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java x: 4 commits (30d) y: 522 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 6 commits (30d) y: 1511 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 1 commits (30d) y: 1002 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 4 commits (30d) y: 796 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java x: 4 commits (30d) y: 206 lines of code clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 1 commits (30d) y: 924 lines of code core/src/main/scala/kafka/server/ReplicaManager.scala x: 7 commits (30d) y: 2203 lines of code tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java x: 3 commits (30d) y: 331 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 2 commits (30d) y: 965 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 2 commits (30d) y: 1203 lines of code core/src/main/scala/kafka/log/LogManager.scala x: 4 commits (30d) y: 1098 lines of code clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 3 commits (30d) y: 351 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteShareGroupOffsetsHandler.java x: 3 commits (30d) y: 130 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupOffsetsResponse.java x: 4 commits (30d) y: 40 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java x: 5 commits (30d) y: 868 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManager.java x: 3 commits (30d) y: 1657 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java x: 2 commits (30d) y: 599 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 2 commits (30d) y: 754 lines of code streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 1 commits (30d) y: 1397 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java x: 1 commits (30d) y: 1027 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 1 commits (30d) y: 1727 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java x: 2 commits (30d) y: 1033 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java x: 1 commits (30d) y: 509 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java x: 1 commits (30d) y: 435 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java x: 2 commits (30d) y: 422 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 2 commits (30d) y: 1718 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 1 commits (30d) y: 754 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java x: 1 commits (30d) y: 412 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 1 commits (30d) y: 556 lines of code clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 4 commits (30d) y: 831 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 2 commits (30d) y: 1385 lines of code clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java x: 4 commits (30d) y: 130 lines of code core/src/main/java/kafka/server/share/ShareFetchUtils.java x: 3 commits (30d) y: 175 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 2 commits (30d) y: 262 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java x: 2 commits (30d) y: 85 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java x: 2 commits (30d) y: 198 lines of code clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java x: 2 commits (30d) y: 378 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java x: 2 commits (30d) y: 307 lines of code metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java x: 1 commits (30d) y: 591 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java x: 1 commits (30d) y: 1156 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java x: 2 commits (30d) y: 359 lines of code core/src/main/scala/kafka/admin/ConfigCommand.scala x: 2 commits (30d) y: 582 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java x: 2 commits (30d) y: 513 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 2 commits (30d) y: 574 lines of code clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java x: 3 commits (30d) y: 164 lines of code metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java x: 2 commits (30d) y: 650 lines of code coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 1 commits (30d) y: 1472 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java x: 1 commits (30d) y: 806 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java x: 2 commits (30d) y: 623 lines of code core/src/main/scala/kafka/server/ControllerApis.scala x: 5 commits (30d) y: 975 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java x: 3 commits (30d) y: 856 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 1 commits (30d) y: 2304 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java x: 1 commits (30d) y: 729 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java x: 1 commits (30d) y: 393 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java x: 1 commits (30d) y: 345 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java x: 1 commits (30d) y: 315 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java x: 1 commits (30d) y: 462 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java x: 1 commits (30d) y: 540 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 1 commits (30d) y: 1371 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 1 commits (30d) y: 1114 lines of code
5425.0
lines of code
  min: 4.0
  average: 291.82
  25th percentile: 48.0
  median: 107.0
  75th percentile: 298.0
  max: 5425.0
0 17.0
commits (30d)
min: 1.0 | average: 1.63 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 17.0

File Size vs. Contributors (30 days): 471 points

clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 5 contributors (30d) y: 4131 lines of code core/src/main/java/kafka/server/share/DelayedShareFetch.java x: 1 contributors (30d) y: 650 lines of code core/src/main/java/kafka/server/share/SharePartition.java x: 4 contributors (30d) y: 2060 lines of code core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 4 contributors (30d) y: 548 lines of code core/src/main/scala/kafka/server/BrokerServer.scala x: 10 contributors (30d) y: 642 lines of code core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 5 contributors (30d) y: 851 lines of code raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 3 contributors (30d) y: 3122 lines of code raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java x: 1 contributors (30d) y: 220 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java x: 1 contributors (30d) y: 93 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java x: 1 contributors (30d) y: 292 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java x: 2 contributors (30d) y: 114 lines of code raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java x: 2 contributors (30d) y: 134 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java x: 1 contributors (30d) y: 38 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java x: 1 contributors (30d) y: 156 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 6 contributors (30d) y: 1746 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java x: 1 contributors (30d) y: 486 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java x: 1 contributors (30d) y: 70 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java x: 1 contributors (30d) y: 8 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 2 contributors (30d) y: 733 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java x: 2 contributors (30d) y: 501 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 1 contributors (30d) y: 492 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java x: 1 contributors (30d) y: 1164 lines of code core/src/main/java/kafka/server/share/PendingRemoteFetches.java x: 1 contributors (30d) y: 56 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java x: 1 contributors (30d) y: 186 lines of code clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 1 contributors (30d) y: 525 lines of code server/src/main/java/org/apache/kafka/server/AssignmentsManager.java x: 1 contributors (30d) y: 367 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 3 contributors (30d) y: 290 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 3 contributors (30d) y: 1650 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java x: 1 contributors (30d) y: 854 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 2 contributors (30d) y: 557 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java x: 1 contributors (30d) y: 1748 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 8 contributors (30d) y: 5425 lines of code tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java x: 1 contributors (30d) y: 137 lines of code tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java x: 1 contributors (30d) y: 323 lines of code tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java x: 2 contributors (30d) y: 1054 lines of code core/src/main/java/kafka/server/TierStateMachine.java x: 2 contributors (30d) y: 169 lines of code core/src/main/scala/kafka/cluster/Partition.scala x: 3 contributors (30d) y: 1320 lines of code core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 2 contributors (30d) y: 680 lines of code metadata/src/main/java/org/apache/kafka/controller/OffsetControlManager.java x: 1 contributors (30d) y: 244 lines of code metadata/src/main/java/org/apache/kafka/controller/QuorumController.java x: 2 contributors (30d) y: 1654 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 2 contributors (30d) y: 719 lines of code raft/src/main/java/org/apache/kafka/raft/RaftClient.java x: 2 contributors (30d) y: 38 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java x: 1 contributors (30d) y: 207 lines of code server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java x: 2 contributors (30d) y: 236 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala x: 2 contributors (30d) y: 818 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala x: 3 contributors (30d) y: 647 lines of code core/src/main/scala/kafka/server/KafkaApis.scala x: 14 contributors (30d) y: 3343 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java x: 1 contributors (30d) y: 873 lines of code core/src/main/java/kafka/server/share/SharePartitionManager.java x: 3 contributors (30d) y: 549 lines of code server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java x: 2 contributors (30d) y: 91 lines of code core/src/main/java/kafka/server/builders/KafkaApisBuilder.java x: 4 contributors (30d) y: 188 lines of code core/src/main/scala/kafka/server/KafkaConfig.scala x: 6 contributors (30d) y: 607 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java x: 4 contributors (30d) y: 564 lines of code server-common/src/main/java/org/apache/kafka/server/common/Feature.java x: 2 contributors (30d) y: 186 lines of code core/src/main/scala/kafka/network/SocketServer.scala x: 3 contributors (30d) y: 1249 lines of code core/src/main/scala/kafka/server/ControllerServer.scala x: 4 contributors (30d) y: 379 lines of code core/src/main/scala/kafka/tools/TestRaftServer.scala x: 3 contributors (30d) y: 397 lines of code core/src/main/scala/kafka/utils/CoreUtils.scala x: 1 contributors (30d) y: 116 lines of code metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java x: 1 contributors (30d) y: 261 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java x: 3 contributors (30d) y: 194 lines of code tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java x: 2 contributors (30d) y: 443 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java x: 3 contributors (30d) y: 522 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 5 contributors (30d) y: 1511 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 1 contributors (30d) y: 1002 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 4 contributors (30d) y: 796 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java x: 4 contributors (30d) y: 206 lines of code clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 1 contributors (30d) y: 924 lines of code core/src/main/scala/kafka/server/ReplicaManager.scala x: 4 contributors (30d) y: 2203 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 1 contributors (30d) y: 965 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 1 contributors (30d) y: 1203 lines of code core/src/main/scala/kafka/log/LogManager.scala x: 3 contributors (30d) y: 1098 lines of code clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 2 contributors (30d) y: 351 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 2 contributors (30d) y: 285 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupOffsetsResponse.java x: 3 contributors (30d) y: 40 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java x: 4 contributors (30d) y: 868 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java x: 2 contributors (30d) y: 599 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 2 contributors (30d) y: 754 lines of code streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 1 contributors (30d) y: 1397 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java x: 1 contributors (30d) y: 1027 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 1 contributors (30d) y: 1727 lines of code clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java x: 2 contributors (30d) y: 50 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java x: 2 contributors (30d) y: 1033 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java x: 1 contributors (30d) y: 435 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java x: 2 contributors (30d) y: 422 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 2 contributors (30d) y: 1718 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 1 contributors (30d) y: 754 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java x: 1 contributors (30d) y: 412 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 1 contributors (30d) y: 556 lines of code clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 4 contributors (30d) y: 831 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 2 contributors (30d) y: 1385 lines of code clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java x: 4 contributors (30d) y: 130 lines of code core/src/main/java/kafka/server/share/ShareFetchUtils.java x: 3 contributors (30d) y: 175 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 2 contributors (30d) y: 262 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java x: 2 contributors (30d) y: 85 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeConfigsResponse.java x: 2 contributors (30d) y: 198 lines of code clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java x: 2 contributors (30d) y: 378 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java x: 2 contributors (30d) y: 307 lines of code metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java x: 1 contributors (30d) y: 591 lines of code core/src/main/scala/kafka/admin/ConfigCommand.scala x: 2 contributors (30d) y: 582 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java x: 2 contributors (30d) y: 513 lines of code clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java x: 3 contributors (30d) y: 164 lines of code metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java x: 2 contributors (30d) y: 650 lines of code coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 1 contributors (30d) y: 1472 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java x: 1 contributors (30d) y: 806 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java x: 2 contributors (30d) y: 623 lines of code core/src/main/scala/kafka/server/AclApis.scala x: 3 contributors (30d) y: 137 lines of code core/src/main/scala/kafka/server/ControllerApis.scala x: 4 contributors (30d) y: 975 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 1 contributors (30d) y: 2304 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java x: 1 contributors (30d) y: 729 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java x: 1 contributors (30d) y: 393 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java x: 1 contributors (30d) y: 345 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java x: 1 contributors (30d) y: 315 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java x: 1 contributors (30d) y: 462 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java x: 1 contributors (30d) y: 540 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 1 contributors (30d) y: 1371 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 1 contributors (30d) y: 1114 lines of code
5425.0
lines of code
  min: 4.0
  average: 291.82
  25th percentile: 48.0
  median: 107.0
  75th percentile: 298.0
  max: 5425.0
0 14.0
contributors (30d)
min: 1.0 | average: 1.47 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 14.0

File Size vs. Commits (90 days): 1135 points

clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 20 commits (90d) y: 4131 lines of code core/src/main/java/kafka/server/share/DelayedShareFetch.java x: 8 commits (90d) y: 650 lines of code core/src/main/java/kafka/server/share/SharePartition.java x: 13 commits (90d) y: 2060 lines of code core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 8 commits (90d) y: 548 lines of code core/src/main/scala/kafka/server/BrokerServer.scala x: 27 commits (90d) y: 642 lines of code core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 12 commits (90d) y: 851 lines of code raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 8 commits (90d) y: 3122 lines of code raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java x: 3 commits (90d) y: 220 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java x: 1 commits (90d) y: 93 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java x: 2 commits (90d) y: 292 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java x: 2 commits (90d) y: 114 lines of code raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java x: 2 commits (90d) y: 134 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java x: 2 commits (90d) y: 38 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java x: 4 commits (90d) y: 156 lines of code clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateSummaryResponse.java x: 3 commits (90d) y: 107 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 21 commits (90d) y: 1746 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java x: 3 commits (90d) y: 486 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java x: 3 commits (90d) y: 70 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionFactory.java x: 1 commits (90d) y: 31 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java x: 1 commits (90d) y: 8 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 6 commits (90d) y: 733 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java x: 7 commits (90d) y: 501 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListStreamsGroupOffsetsOptions.java x: 3 commits (90d) y: 13 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 2 commits (90d) y: 492 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java x: 3 commits (90d) y: 1164 lines of code core/src/main/java/kafka/server/share/PendingRemoteFetches.java x: 1 commits (90d) y: 56 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java x: 5 commits (90d) y: 186 lines of code clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 1 commits (90d) y: 525 lines of code clients/src/main/java/org/apache/kafka/clients/admin/DescribeUserScramCredentialsResult.java x: 2 commits (90d) y: 81 lines of code server/src/main/java/org/apache/kafka/server/AssignmentsManager.java x: 2 commits (90d) y: 367 lines of code tools/src/main/java/org/apache/kafka/tools/ClusterTool.java x: 1 commits (90d) y: 165 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 4 commits (90d) y: 290 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 8 commits (90d) y: 1650 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java x: 6 commits (90d) y: 854 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 4 commits (90d) y: 557 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java x: 4 commits (90d) y: 1748 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 31 commits (90d) y: 5425 lines of code streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java x: 2 commits (90d) y: 10 lines of code tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java x: 1 commits (90d) y: 137 lines of code tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java x: 1 commits (90d) y: 323 lines of code tools/src/main/java/org/apache/kafka/tools/TopicCommand.java x: 1 commits (90d) y: 834 lines of code tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java x: 6 commits (90d) y: 1054 lines of code core/src/main/scala/kafka/cluster/Partition.scala x: 10 commits (90d) y: 1320 lines of code core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 5 commits (90d) y: 680 lines of code metadata/src/main/java/org/apache/kafka/controller/OffsetControlManager.java x: 2 commits (90d) y: 244 lines of code metadata/src/main/java/org/apache/kafka/controller/QuorumController.java x: 7 commits (90d) y: 1654 lines of code metadata/src/main/java/org/apache/kafka/image/MetadataProvenance.java x: 1 commits (90d) y: 65 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 3 commits (90d) y: 719 lines of code raft/src/main/java/org/apache/kafka/raft/RaftUtil.java x: 2 commits (90d) y: 653 lines of code raft/src/main/java/org/apache/kafka/raft/internals/KafkaRaftMetrics.java x: 2 commits (90d) y: 223 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java x: 2 commits (90d) y: 207 lines of code server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java x: 7 commits (90d) y: 236 lines of code server-common/src/main/java/org/apache/kafka/server/common/ShareVersion.java x: 2 commits (90d) y: 49 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala x: 5 commits (90d) y: 818 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala x: 7 commits (90d) y: 647 lines of code core/src/main/scala/kafka/server/KafkaApis.scala x: 39 commits (90d) y: 3343 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java x: 2 commits (90d) y: 873 lines of code core/src/main/java/kafka/server/share/SharePartitionManager.java x: 9 commits (90d) y: 549 lines of code server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java x: 3 commits (90d) y: 91 lines of code clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 1 commits (90d) y: 242 lines of code streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/StickyTaskAssignor.java x: 1 commits (90d) y: 380 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommandOptions.java x: 4 commits (90d) y: 175 lines of code core/src/main/java/kafka/server/builders/KafkaApisBuilder.java x: 7 commits (90d) y: 188 lines of code core/src/main/scala/kafka/server/AutoTopicCreationManager.scala x: 3 commits (90d) y: 201 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroupConfig.java x: 5 commits (90d) y: 121 lines of code core/src/main/scala/kafka/server/KafkaConfig.scala x: 23 commits (90d) y: 607 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java x: 11 commits (90d) y: 564 lines of code core/src/main/scala/kafka/network/SocketServer.scala x: 5 commits (90d) y: 1249 lines of code core/src/main/scala/kafka/server/ControllerServer.scala x: 12 commits (90d) y: 379 lines of code core/src/main/scala/kafka/tools/TestRaftServer.scala x: 4 commits (90d) y: 397 lines of code metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistration.java x: 5 commits (90d) y: 333 lines of code metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java x: 1 commits (90d) y: 261 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java x: 4 commits (90d) y: 194 lines of code server-common/src/main/java/org/apache/kafka/server/network/EndpointReadyFutures.java x: 3 commits (90d) y: 152 lines of code tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java x: 2 commits (90d) y: 443 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java x: 11 commits (90d) y: 522 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 7 commits (90d) y: 1511 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 2 commits (90d) y: 1002 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java x: 1 commits (90d) y: 118 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 4 commits (90d) y: 796 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java x: 2 commits (90d) y: 171 lines of code clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 1 commits (90d) y: 924 lines of code core/src/main/scala/kafka/server/DelayedProduce.scala x: 2 commits (90d) y: 88 lines of code core/src/main/scala/kafka/server/ReplicaManager.scala x: 21 commits (90d) y: 2203 lines of code tools/src/main/java/org/apache/kafka/tools/streams/StreamsGroupCommand.java x: 3 commits (90d) y: 331 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 3 commits (90d) y: 965 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 4 commits (90d) y: 1203 lines of code core/src/main/scala/kafka/log/LogManager.scala x: 9 commits (90d) y: 1098 lines of code core/src/main/scala/kafka/server/AbstractFetcherManager.scala x: 1 commits (90d) y: 184 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java x: 7 commits (90d) y: 292 lines of code clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 14 commits (90d) y: 351 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 10 commits (90d) y: 285 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DeleteShareGroupOffsetsHandler.java x: 3 commits (90d) y: 130 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupOffsetsResponse.java x: 5 commits (90d) y: 40 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java x: 15 commits (90d) y: 868 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManager.java x: 3 commits (90d) y: 1657 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java x: 5 commits (90d) y: 599 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 3 commits (90d) y: 754 lines of code streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 1 commits (90d) y: 1397 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java x: 2 commits (90d) y: 1027 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java x: 1 commits (90d) y: 218 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 3 commits (90d) y: 1727 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 1 commits (90d) y: 858 lines of code clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java x: 3 commits (90d) y: 50 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java x: 4 commits (90d) y: 1033 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java x: 3 commits (90d) y: 509 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java x: 1 commits (90d) y: 435 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java x: 4 commits (90d) y: 608 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java x: 4 commits (90d) y: 422 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 5 commits (90d) y: 1718 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java x: 2 commits (90d) y: 487 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java x: 3 commits (90d) y: 274 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java x: 3 commits (90d) y: 412 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 1 commits (90d) y: 556 lines of code clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 2 commits (90d) y: 528 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 4 commits (90d) y: 1385 lines of code clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java x: 6 commits (90d) y: 130 lines of code core/src/main/java/kafka/server/share/ShareFetchUtils.java x: 6 commits (90d) y: 175 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 5 commits (90d) y: 262 lines of code clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsResponse.java x: 3 commits (90d) y: 39 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java x: 2 commits (90d) y: 307 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java x: 4 commits (90d) y: 829 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java x: 4 commits (90d) y: 757 lines of code metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java x: 4 commits (90d) y: 591 lines of code metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java x: 6 commits (90d) y: 376 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaShareConsumer.java x: 5 commits (90d) y: 148 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeShareGroupsHandler.java x: 2 commits (90d) y: 150 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupOffsetsRequest.java x: 4 commits (90d) y: 59 lines of code clients/src/main/java/org/apache/kafka/common/requests/ShareFetchRequest.java x: 5 commits (90d) y: 166 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java x: 4 commits (90d) y: 1156 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java x: 2 commits (90d) y: 359 lines of code core/src/main/scala/kafka/raft/RaftManager.scala x: 5 commits (90d) y: 244 lines of code core/src/main/scala/kafka/admin/ConfigCommand.scala x: 5 commits (90d) y: 582 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java x: 7 commits (90d) y: 513 lines of code core/src/main/scala/kafka/server/FetchSession.scala x: 2 commits (90d) y: 580 lines of code server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java x: 7 commits (90d) y: 58 lines of code metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java x: 6 commits (90d) y: 650 lines of code coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 5 commits (90d) y: 1472 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Group.java x: 4 commits (90d) y: 74 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java x: 3 commits (90d) y: 806 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/share/ShareGroup.java x: 3 commits (90d) y: 186 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java x: 7 commits (90d) y: 623 lines of code core/src/main/scala/kafka/server/ControllerApis.scala x: 6 commits (90d) y: 975 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/KRaftMetadataRequestBenchmark.java x: 5 commits (90d) y: 210 lines of code connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorMaker.java x: 2 commits (90d) y: 268 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java x: 10 commits (90d) y: 856 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 2 commits (90d) y: 2304 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java x: 1 commits (90d) y: 729 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/DelegatingClassLoader.java x: 1 commits (90d) y: 197 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java x: 1 commits (90d) y: 393 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java x: 1 commits (90d) y: 345 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java x: 1 commits (90d) y: 315 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java x: 1 commits (90d) y: 287 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java x: 1 commits (90d) y: 462 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java x: 3 commits (90d) y: 540 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupConfig.java x: 3 commits (90d) y: 280 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java x: 5 commits (90d) y: 561 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 6 commits (90d) y: 1371 lines of code core/src/main/scala/kafka/server/ClientQuotaManager.scala x: 2 commits (90d) y: 405 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 7 commits (90d) y: 1114 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LocalLog.java x: 3 commits (90d) y: 666 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java x: 2 commits (90d) y: 756 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java x: 1 commits (90d) y: 414 lines of code storage/src/main/java/org/apache/kafka/storage/internals/epoch/LeaderEpochFileCache.java x: 2 commits (90d) y: 341 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogSegment.java x: 3 commits (90d) y: 531 lines of code metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 7 commits (90d) y: 1975 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/SimpleAssignor.java x: 4 commits (90d) y: 252 lines of code clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java x: 2 commits (90d) y: 420 lines of code core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala x: 3 commits (90d) y: 379 lines of code clients/src/main/java/org/apache/kafka/common/utils/LogContext.java x: 1 commits (90d) y: 636 lines of code core/src/main/scala/kafka/tools/DumpLogSegments.scala x: 3 commits (90d) y: 566 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java x: 2 commits (90d) y: 548 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java x: 1 commits (90d) y: 955 lines of code clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java x: 3 commits (90d) y: 639 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java x: 2 commits (90d) y: 1174 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 1 commits (90d) y: 1257 lines of code clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java x: 1 commits (90d) y: 541 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java x: 11 commits (90d) y: 1118 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 3 commits (90d) y: 1852 lines of code server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java x: 2 commits (90d) y: 794 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java x: 1 commits (90d) y: 789 lines of code streams/src/main/java/org/apache/kafka/streams/Topology.java x: 3 commits (90d) y: 449 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java x: 11 commits (90d) y: 183 lines of code
5425.0
lines of code
  min: 2.0
  average: 190.21
  25th percentile: 36.0
  median: 74.0
  75th percentile: 186.0
  max: 5425.0
0 39.0
commits (90d)
min: 1.0 | average: 1.94 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 39.0

File Size vs. Contributors (90 days): 1135 points

clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 15 contributors (90d) y: 4131 lines of code core/src/main/java/kafka/server/share/DelayedShareFetch.java x: 2 contributors (90d) y: 650 lines of code core/src/main/java/kafka/server/share/SharePartition.java x: 6 contributors (90d) y: 2060 lines of code core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 5 contributors (90d) y: 548 lines of code core/src/main/scala/kafka/server/BrokerServer.scala x: 17 contributors (90d) y: 642 lines of code core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 9 contributors (90d) y: 851 lines of code raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 5 contributors (90d) y: 3122 lines of code raft/src/main/java/org/apache/kafka/raft/internals/KRaftControlRecordStateMachine.java x: 2 contributors (90d) y: 220 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsBatchReader.java x: 1 contributors (90d) y: 93 lines of code raft/src/main/java/org/apache/kafka/raft/internals/RecordsIterator.java x: 2 contributors (90d) y: 292 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotReader.java x: 2 contributors (90d) y: 114 lines of code raft/src/main/java/org/apache/kafka/snapshot/Snapshots.java x: 2 contributors (90d) y: 134 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java x: 2 contributors (90d) y: 38 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListShareGroupOffsetsHandler.java x: 1 contributors (90d) y: 156 lines of code clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateSummaryResponse.java x: 3 contributors (90d) y: 107 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 9 contributors (90d) y: 1746 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/DefaultStatePersister.java x: 3 contributors (90d) y: 486 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/NoOpStatePersister.java x: 2 contributors (90d) y: 70 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionFactory.java x: 1 contributors (90d) y: 31 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PartitionStateSummaryData.java x: 1 contributors (90d) y: 8 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 3 contributors (90d) y: 733 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ShareGroupCommand.java x: 3 contributors (90d) y: 501 lines of code clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 1 contributors (90d) y: 492 lines of code tools/src/main/java/org/apache/kafka/tools/consumer/group/ConsumerGroupCommand.java x: 1 contributors (90d) y: 1164 lines of code core/src/main/java/kafka/server/share/PendingRemoteFetches.java x: 1 contributors (90d) y: 56 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareSessionHandler.java x: 4 contributors (90d) y: 186 lines of code clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 1 contributors (90d) y: 525 lines of code server/src/main/java/org/apache/kafka/server/AssignmentsManager.java x: 2 contributors (90d) y: 367 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 4 contributors (90d) y: 290 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 5 contributors (90d) y: 1650 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java x: 3 contributors (90d) y: 854 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 3 contributors (90d) y: 557 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java x: 3 contributors (90d) y: 1748 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 10 contributors (90d) y: 5425 lines of code streams/src/main/java/org/apache/kafka/streams/processor/BatchingStateRestoreCallback.java x: 2 contributors (90d) y: 10 lines of code tools/src/main/java/org/apache/kafka/tools/DeleteRecordsCommand.java x: 1 contributors (90d) y: 137 lines of code tools/src/main/java/org/apache/kafka/tools/LeaderElectionCommand.java x: 1 contributors (90d) y: 323 lines of code tools/src/main/java/org/apache/kafka/tools/TopicCommand.java x: 1 contributors (90d) y: 834 lines of code tools/src/main/java/org/apache/kafka/tools/reassign/ReassignPartitionsCommand.java x: 6 contributors (90d) y: 1054 lines of code core/src/main/java/kafka/server/TierStateMachine.java x: 3 contributors (90d) y: 169 lines of code core/src/main/scala/kafka/cluster/Partition.scala x: 6 contributors (90d) y: 1320 lines of code core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 5 contributors (90d) y: 680 lines of code metadata/src/main/java/org/apache/kafka/controller/OffsetControlManager.java x: 2 contributors (90d) y: 244 lines of code metadata/src/main/java/org/apache/kafka/controller/QuorumController.java x: 6 contributors (90d) y: 1654 lines of code metadata/src/main/java/org/apache/kafka/image/MetadataProvenance.java x: 1 contributors (90d) y: 65 lines of code raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 3 contributors (90d) y: 719 lines of code raft/src/main/java/org/apache/kafka/snapshot/RecordsSnapshotWriter.java x: 2 contributors (90d) y: 207 lines of code server-common/src/main/java/org/apache/kafka/server/common/MetadataVersion.java x: 5 contributors (90d) y: 236 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ListTransactionsOptions.java x: 2 contributors (90d) y: 64 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionCoordinator.scala x: 4 contributors (90d) y: 818 lines of code core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala x: 6 contributors (90d) y: 647 lines of code core/src/main/scala/kafka/server/KafkaApis.scala x: 20 contributors (90d) y: 3343 lines of code tools/src/main/java/org/apache/kafka/tools/TransactionsCommand.java x: 2 contributors (90d) y: 873 lines of code core/src/main/java/kafka/server/share/SharePartitionManager.java x: 6 contributors (90d) y: 549 lines of code server/src/main/java/org/apache/kafka/server/share/session/ShareSessionCache.java x: 3 contributors (90d) y: 91 lines of code clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 1 contributors (90d) y: 242 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java x: 3 contributors (90d) y: 284 lines of code streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors/StickyTaskAssignor.java x: 1 contributors (90d) y: 380 lines of code core/src/main/java/kafka/server/builders/KafkaApisBuilder.java x: 5 contributors (90d) y: 188 lines of code core/src/main/scala/kafka/server/AutoTopicCreationManager.scala x: 3 contributors (90d) y: 201 lines of code core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala x: 6 contributors (90d) y: 246 lines of code core/src/main/scala/kafka/server/KafkaConfig.scala x: 17 contributors (90d) y: 607 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java x: 7 contributors (90d) y: 564 lines of code core/src/main/scala/kafka/network/SocketServer.scala x: 5 contributors (90d) y: 1249 lines of code core/src/main/scala/kafka/server/ControllerServer.scala x: 7 contributors (90d) y: 379 lines of code core/src/main/scala/kafka/tools/TestRaftServer.scala x: 4 contributors (90d) y: 397 lines of code metadata/src/main/java/org/apache/kafka/metadata/BrokerRegistration.java x: 4 contributors (90d) y: 333 lines of code metadata/src/main/java/org/apache/kafka/metadata/ListenerInfo.java x: 1 contributors (90d) y: 261 lines of code metadata/src/main/java/org/apache/kafka/metadata/authorizer/StandardAuthorizer.java x: 4 contributors (90d) y: 194 lines of code tools/src/main/java/org/apache/kafka/tools/MetadataQuorumCommand.java x: 2 contributors (90d) y: 443 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java x: 3 contributors (90d) y: 522 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 5 contributors (90d) y: 1511 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 2 contributors (90d) y: 1002 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java x: 1 contributors (90d) y: 118 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 4 contributors (90d) y: 796 lines of code clients/src/main/java/org/apache/kafka/common/requests/ProduceRequest.java x: 2 contributors (90d) y: 171 lines of code clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 1 contributors (90d) y: 924 lines of code core/src/main/scala/kafka/server/DelayedProduce.scala x: 2 contributors (90d) y: 88 lines of code core/src/main/scala/kafka/server/ReplicaManager.scala x: 12 contributors (90d) y: 2203 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 2 contributors (90d) y: 965 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 3 contributors (90d) y: 1203 lines of code core/src/main/scala/kafka/log/LogManager.scala x: 5 contributors (90d) y: 1098 lines of code core/src/main/scala/kafka/server/AbstractFetcherManager.scala x: 1 contributors (90d) y: 184 lines of code jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java x: 5 contributors (90d) y: 292 lines of code clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 10 contributors (90d) y: 351 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 8 contributors (90d) y: 285 lines of code clients/src/main/java/org/apache/kafka/common/requests/DeleteShareGroupOffsetsResponse.java x: 3 contributors (90d) y: 40 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java x: 7 contributors (90d) y: 868 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManager.java x: 3 contributors (90d) y: 1657 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java x: 3 contributors (90d) y: 599 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 3 contributors (90d) y: 754 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsCoordinatorRecordHelpers.java x: 3 contributors (90d) y: 327 lines of code streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 1 contributors (90d) y: 1397 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java x: 2 contributors (90d) y: 1027 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java x: 1 contributors (90d) y: 218 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 3 contributors (90d) y: 1727 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 1 contributors (90d) y: 858 lines of code metadata/src/main/java/org/apache/kafka/metadata/bootstrap/BootstrapMetadata.java x: 3 contributors (90d) y: 145 lines of code clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupHeartbeatResponse.java x: 3 contributors (90d) y: 50 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractHerder.java x: 3 contributors (90d) y: 1033 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/AbstractWorkerSourceTask.java x: 2 contributors (90d) y: 509 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectMetricsRegistry.java x: 1 contributors (90d) y: 435 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java x: 2 contributors (90d) y: 608 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java x: 2 contributors (90d) y: 422 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java x: 2 contributors (90d) y: 487 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 2 contributors (90d) y: 754 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSourceTask.java x: 2 contributors (90d) y: 274 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 1 contributors (90d) y: 556 lines of code clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 5 contributors (90d) y: 831 lines of code clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 2 contributors (90d) y: 528 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 4 contributors (90d) y: 1385 lines of code clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java x: 5 contributors (90d) y: 130 lines of code core/src/main/java/kafka/server/share/ShareFetchUtils.java x: 3 contributors (90d) y: 175 lines of code clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 4 contributors (90d) y: 262 lines of code clients/src/main/java/org/apache/kafka/common/requests/DescribeShareGroupOffsetsResponse.java x: 3 contributors (90d) y: 73 lines of code clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchResponse.java x: 2 contributors (90d) y: 307 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java x: 2 contributors (90d) y: 829 lines of code share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareGroupOffset.java x: 1 contributors (90d) y: 200 lines of code metadata/src/main/java/org/apache/kafka/controller/ConfigurationControlManager.java x: 4 contributors (90d) y: 591 lines of code metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java x: 5 contributors (90d) y: 376 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeShareGroupsHandler.java x: 2 contributors (90d) y: 150 lines of code clients/src/main/java/org/apache/kafka/common/requests/ShareFetchRequest.java x: 5 contributors (90d) y: 166 lines of code server-common/src/main/java/org/apache/kafka/server/share/persister/PersisterStateManager.java x: 3 contributors (90d) y: 1156 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogCleaner.java x: 2 contributors (90d) y: 359 lines of code core/src/main/scala/kafka/raft/RaftManager.scala x: 3 contributors (90d) y: 244 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java x: 5 contributors (90d) y: 513 lines of code core/src/main/scala/kafka/server/FetchSession.scala x: 2 contributors (90d) y: 580 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 4 contributors (90d) y: 574 lines of code clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java x: 4 contributors (90d) y: 164 lines of code server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java x: 5 contributors (90d) y: 58 lines of code coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 4 contributors (90d) y: 1472 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java x: 2 contributors (90d) y: 806 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java x: 3 contributors (90d) y: 623 lines of code core/src/main/scala/kafka/server/ControllerApis.scala x: 5 contributors (90d) y: 975 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java x: 3 contributors (90d) y: 856 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 1 contributors (90d) y: 2304 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/IncrementalCooperativeAssignor.java x: 1 contributors (90d) y: 729 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/isolation/PluginUtils.java x: 1 contributors (90d) y: 393 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/resources/ConnectorsResource.java x: 1 contributors (90d) y: 345 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/ConnectorOffsetBackingStore.java x: 1 contributors (90d) y: 315 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStore.java x: 1 contributors (90d) y: 287 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java x: 1 contributors (90d) y: 462 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LogConfig.java x: 3 contributors (90d) y: 540 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManagers.java x: 2 contributors (90d) y: 329 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 6 contributors (90d) y: 1371 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 2 contributors (90d) y: 1114 lines of code storage/src/main/java/org/apache/kafka/storage/internals/log/LocalLog.java x: 3 contributors (90d) y: 666 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java x: 1 contributors (90d) y: 756 lines of code storage/src/main/java/org/apache/kafka/server/log/remote/storage/RemoteLogManagerConfig.java x: 1 contributors (90d) y: 414 lines of code metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 7 contributors (90d) y: 1975 lines of code metadata/src/main/java/org/apache/kafka/metadata/PartitionRegistration.java x: 2 contributors (90d) y: 404 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/assignor/SimpleAssignor.java x: 4 contributors (90d) y: 252 lines of code clients/src/main/java/org/apache/kafka/common/utils/LogContext.java x: 1 contributors (90d) y: 636 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/InMemoryWindowStore.java x: 2 contributors (90d) y: 548 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/DefaultStateUpdater.java x: 1 contributors (90d) y: 955 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java x: 2 contributors (90d) y: 1174 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 1 contributors (90d) y: 1257 lines of code clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java x: 1 contributors (90d) y: 541 lines of code streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java x: 3 contributors (90d) y: 1118 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 2 contributors (90d) y: 1852 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java x: 1 contributors (90d) y: 789 lines of code
5425.0
lines of code
  min: 2.0
  average: 190.21
  25th percentile: 36.0
  median: 74.0
  75th percentile: 186.0
  max: 5425.0
0 20.0
contributors (90d)
min: 1.0 | average: 1.64 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 20.0