apache / kafka-merge-queue-sandbox
File Size

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

Intro
Learn more...
File Size Overall
16% | 16% | 26% | 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
java15% | 14% | 26% | 18% | 24%
scala32% | 28% | 17% | 12% | 7%
py0% | 0% | 41% | 0% | 58%
xml0% | 0% | 91% | 0% | 8%
xsl0% | 0% | 0% | 100% | 0%
yaml0% | 0% | 0% | 51% | 48%
rdf0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
awk0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
core37% | 27% | 16% | 12% | 6%
streams17% | 13% | 28% | 18% | 22%
clients12% | 17% | 20% | 18% | 31%
connect14% | 15% | 28% | 16% | 24%
group-coordinator30% | 20% | 24% | 13% | 10%
metadata17% | 6% | 30% | 23% | 22%
raft25% | 17% | 25% | 16% | 15%
tools12% | 25% | 46% | 10% | 4%
generator26% | 8% | 32% | 16% | 16%
coordinator-common53% | 0% | 0% | 21% | 25%
storage0% | 19% | 31% | 24% | 24%
share-coordinator0% | 62% | 10% | 17% | 9%
server-common0% | 9% | 22% | 28% | 38%
server0% | 17% | 19% | 32% | 31%
trogdor0% | 0% | 50% | 17% | 32%
jmh-benchmarks0% | 0% | 38% | 36% | 24%
shell0% | 0% | 24% | 25% | 50%
gradle0% | 0% | 66% | 29% | 3%
committer-tools0% | 0% | 62% | 0% | 37%
release0% | 0% | 38% | 0% | 61%
transaction-coordinator0% | 0% | 0% | 43% | 56%
config0% | 0% | 0% | 70% | 29%
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
 4156 185
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4063 149
KafkaRaftClient.java
in raft/src/main/java/org/apache/kafka/raft
 3047 149
KafkaApis.scala
in core/src/main/scala/kafka/server
 2916 86
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 2305 127
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2100 83
ReplicationControlManager.java
in metadata/src/main/java/org/apache/kafka/controller
 1969 79
InternalTopologyBuilder.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1856 159
SharePartition.java
in core/src/main/java/kafka/server/share
 1802 98
TaskManager.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1714 116
QuorumController.java
in metadata/src/main/java/org/apache/kafka/controller
 1671 111
Worker.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1669 90
RemoteLogManager.java
in core/src/main/java/kafka/log/remote
 1667 111
MessageDataGenerator.java
in generator/src/main/java/org/apache/kafka/message
 1611 51
AsyncKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1539 97
GroupCoordinator.scala
in core/src/main/scala/kafka/coordinator/group
 1482 66
CoordinatorRuntime.java
in coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime
 1460 83
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
 1398 81
TransactionManager.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 1369 129
StreamsConfig.java
in streams/src/main/java/org/apache/kafka/streams
 1338 49
UnifiedLog.scala
in core/src/main/scala/kafka/log
 1321 87
Partition.scala
in core/src/main/scala/kafka/cluster
 1310 75
StreamThread.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1299 60
StreamsPartitionAssignor.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1267 49
SocketServer.scala
in core/src/main/scala/kafka/network
 1254 88
AbstractCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1169 84
ConsumerGroupCommand.java
in tools/src/main/java/org/apache/kafka/tools/consumer/group
 1166 44
KTableImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1162 68
ConsumerCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1150 55
LogManager.scala
in core/src/main/scala/kafka/log
 1128 60
NetworkClient.java
in clients/src/main/java/org/apache/kafka/clients
 1124 87
GroupCoordinatorService.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 1064 41
KStreamImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1062 81
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
Selector.java
in clients/src/main/java/org/apache/kafka/common/network
 1030 80
ReassignPartitionsCommand.java
in tools/src/main/java/org/apache/kafka/tools/reassign
 1027 35
AbstractStickyAssignor.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1024 49
StreamTask.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1023 69
AbstractHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1021 66
ClassicKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 989 67
PersisterStateManager.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 978 64
ControllerApis.scala
in core/src/main/scala/kafka/server
 977 44
ShareConsumeRequestManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 958 53
DefaultStateUpdater.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 954 77
SubscriptionState.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 954 143
CommitRequestManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 947 60
Utils.java
in clients/src/main/java/org/apache/kafka/common/utils
 924 89
GroupMetadataManager.scala
in core/src/main/scala/kafka/coordinator/group
 916 43
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
 4156 185
InternalTopologyBuilder.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1856 159
KafkaRaftClient.java
in raft/src/main/java/org/apache/kafka/raft
 3047 149
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4063 149
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
 631 129
TransactionManager.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 1369 129
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 2305 127
TaskManager.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1714 116
QuorumController.java
in metadata/src/main/java/org/apache/kafka/controller
 1671 111
RemoteLogManager.java
in core/src/main/java/kafka/log/remote
 1667 111
ConfigDef.java
in clients/src/main/java/org/apache/kafka/common/config
 1043 104
SharePartition.java
in core/src/main/java/kafka/server/share
 1802 98
AsyncKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1539 97
Worker.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1669 90
Utils.java
in clients/src/main/java/org/apache/kafka/common/utils
 924 89
SocketServer.scala
in core/src/main/scala/kafka/network
 1254 88
UnifiedLog.scala
in core/src/main/scala/kafka/log
 1321 87
NetworkClient.java
in clients/src/main/java/org/apache/kafka/clients
 1124 87
KafkaApis.scala
in core/src/main/scala/kafka/server
 2916 86
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
 1169 84
CoordinatorRuntime.java
in coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime
 1460 83
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2100 83
ClassicGroup.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic
 804 81
KStreamImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1062 81
KafkaStreams.java
in streams/src/main/java/org/apache/kafka/streams
 1398 81
Selector.java
in clients/src/main/java/org/apache/kafka/common/network
 1030 80
ReplicationControlManager.java
in metadata/src/main/java/org/apache/kafka/controller
 1969 79
DefaultStateUpdater.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 954 77
Partition.scala
in core/src/main/scala/kafka/cluster
 1310 75
StreamsMetricsImpl.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics
 829 75
MockConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 535 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
 836 71
MemoryRecordsBuilder.java
in clients/src/main/java/org/apache/kafka/common/record
 567 70
AbstractMembershipManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 745 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
 1023 69
AbstractLegacyRecordBatch.java
in clients/src/main/java/org/apache/kafka/common/record
 464 69
KTableImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1162 68
MemoryRecords.java
in clients/src/main/java/org/apache/kafka/common/record
 648 67
ClassicKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 989 67
GroupCoordinator.scala
in core/src/main/scala/kafka/coordinator/group
 1482 66
AbstractHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1021 66
ConsumerGroup.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer
 754 66
DefaultRecordBatch.java
in clients/src/main/java/org/apache/kafka/common/record
 540 66
Files With Long Lines (Top 50)

There are 1181 files with lines longer than 120 characters. In total, there are 9077 long lines.

File# lines# units# long lines
RequestConvertToJson.java
in server/src/main/java/org/apache/kafka/network
 778 6 140
Worker.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1669 90 134
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 2305 127 130
ProducerConfig.java
in clients/src/main/java/org/apache/kafka/clients/producer
 511 11 122
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4063 149 111
KafkaApis.scala
in core/src/main/scala/kafka/server
 2916 86 110
ConsumerGroupCommand.java
in tools/src/main/java/org/apache/kafka/tools/consumer/group
 1166 44 109
StreamsConfig.java
in streams/src/main/java/org/apache/kafka/streams
 1338 49 103
RemoteLogManager.java
in core/src/main/java/kafka/log/remote
 1667 111 97
GroupCoordinatorConfig.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 424 37 96
CommonClientConfigs.java
in clients/src/main/java/org/apache/kafka/clients
 238 7 91
SaslConfigs.java
in clients/src/main/java/org/apache/kafka/common/config
 176 1 87
LogConfig.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 549 42 78
BrokerSecurityConfigs.java
in clients/src/main/java/org/apache/kafka/common/config/internals
 156 - 77
ConfigCommand.scala
in core/src/main/scala/kafka/admin
 564 17 73
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2100 83 73
ReassignPartitionsCommand.java
in tools/src/main/java/org/apache/kafka/tools/reassign
 1027 35 70
SharePartition.java
in core/src/main/java/kafka/server/share
 1802 98 70
AclCommand.java
in tools/src/main/java/org/apache/kafka/tools
 532 19 63
ConnectMetricsRegistry.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 371 13 63
KafkaConfig.scala
in core/src/main/scala/kafka/server
 637 22 61
ReplicationConfigs.java
in server/src/main/java/org/apache/kafka/server/config
 134 - 61
RemoteLogManagerConfig.java
in storage/src/main/java/org/apache/kafka/server/log/remote/storage
 414 35 60
GroupMetadataManager.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 4156 185 56
UnifiedLog.scala
in core/src/main/scala/kafka/log
 1321 87 55
ConnectorConfig.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 590 31 55
AbstractStickyAssignor.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1024 49 53
PersisterStateManager.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 978 64 52
TopicCommand.java
in tools/src/main/java/org/apache/kafka/tools
 836 71 52
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
 1398 81 51
ServerLogConfigs.java
in server-common/src/main/java/org/apache/kafka/server/config
 112 - 50
TaskAssignmentUtils.java
in streams/src/main/java/org/apache/kafka/streams/processor/assignment
 780 33 49
ConsumerCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1150 55 48
ShareConsumeRequestManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 958 53 47
ConsumerGroupCommandOptions.java
in tools/src/main/java/org/apache/kafka/tools/consumer/group
 244 3 45
SocketServer.scala
in core/src/main/scala/kafka/network
 1254 88 44
KTableImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1162 68 44
ConfigDef.java
in clients/src/main/java/org/apache/kafka/common/config
 1043 104 44
DynamicBrokerConfig.scala
in core/src/main/scala/kafka/server
 830 64 42
TransactionStateManager.scala
in core/src/main/scala/kafka/coordinator/transaction
 631 24 42
ServerConfigs.java
in server/src/main/java/org/apache/kafka/server/config
 102 - 42
KRaftConfigs.java
in server/src/main/java/org/apache/kafka/server/config
 101 - 42
DistributedConfig.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 573 29 42
StreamsPartitionAssignor.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1267 49 42
ConsumerConfig.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 559 13 42
TransactionCoordinator.scala
in core/src/main/scala/kafka/coordinator/transaction
 806 19 40
QuotaConfig.java
in server-common/src/main/java/org/apache/kafka/server/config
 178 15 38
AbstractHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1021 66 38
GroupMetadataManager.scala
in core/src/main/scala/kafka/coordinator/group
 916 43 36
Correlations

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

clients/src/main/java/org/apache/kafka/clients/ApiVersions.java x: 1 commits (all time) y: 35 lines of code clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java x: 1 commits (all time) y: 17 lines of code clients/src/main/java/org/apache/kafka/clients/ClientRequest.java x: 1 commits (all time) y: 77 lines of code clients/src/main/java/org/apache/kafka/clients/ClientResponse.java x: 1 commits (all time) y: 109 lines of code clients/src/main/java/org/apache/kafka/clients/ClientUtils.java x: 1 commits (all time) y: 224 lines of code clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java x: 1 commits (all time) y: 302 lines of code clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 1 commits (all time) y: 238 lines of code clients/src/main/java/org/apache/kafka/clients/ConnectionState.java x: 1 commits (all time) y: 10 lines of code clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java x: 1 commits (all time) y: 406 lines of code clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java x: 1 commits (all time) y: 96 lines of code clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 1 commits (all time) y: 525 lines of code clients/src/main/java/org/apache/kafka/clients/MetadataSnapshot.java x: 1 commits (all time) y: 178 lines of code clients/src/main/java/org/apache/kafka/clients/NetworkClient.java x: 1 commits (all time) y: 1124 lines of code clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionSpec.java x: 1 commits (all time) y: 57 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java x: 1 commits (all time) y: 154 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 1 commits (all time) y: 247 lines of code clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 1 commits (all time) y: 4063 lines of code clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java x: 1 commits (all time) y: 133 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java x: 1 commits (all time) y: 355 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java x: 1 commits (all time) y: 199 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java x: 1 commits (all time) y: 325 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListOffsetsHandler.java x: 1 commits (all time) y: 185 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 1 commits (all time) y: 559 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java x: 1 commits (all time) y: 123 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 1 commits (all time) y: 285 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java x: 1 commits (all time) y: 1169 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java x: 1 commits (all time) y: 328 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java x: 1 commits (all time) y: 745 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java x: 1 commits (all time) y: 1024 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 1 commits (all time) y: 1539 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 1 commits (all time) y: 989 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 1 commits (all time) y: 947 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 1 commits (all time) y: 1150 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java x: 1 commits (all time) y: 446 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java x: 1 commits (all time) y: 596 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 1 commits (all time) y: 958 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java x: 1 commits (all time) y: 842 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java x: 1 commits (all time) y: 804 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java x: 1 commits (all time) y: 498 lines of code clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 1 commits (all time) y: 825 lines of code clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java x: 1 commits (all time) y: 430 lines of code clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 1 commits (all time) y: 511 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java x: 1 commits (all time) y: 373 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 1 commits (all time) y: 785 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 1 commits (all time) y: 1369 lines of code clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java x: 1 commits (all time) y: 417 lines of code clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java x: 1 commits (all time) y: 1043 lines of code clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java x: 1 commits (all time) y: 263 lines of code clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java x: 1 commits (all time) y: 697 lines of code clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java x: 1 commits (all time) y: 910 lines of code clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java x: 1 commits (all time) y: 464 lines of code clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java x: 1 commits (all time) y: 540 lines of code clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java x: 1 commits (all time) y: 648 lines of code clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java x: 1 commits (all time) y: 383 lines of code clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java x: 1 commits (all time) y: 482 lines of code clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java x: 1 commits (all time) y: 669 lines of code clients/src/main/java/org/apache/kafka/common/utils/LogContext.java x: 1 commits (all time) y: 631 lines of code clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 1 commits (all time) y: 924 lines of code connect/api/src/main/java/org/apache/kafka/connect/data/Values.java x: 1 commits (all time) y: 1048 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 1 commits (all time) y: 1669 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 1 commits (all time) y: 732 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java x: 1 commits (all time) y: 573 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 1 commits (all time) y: 2305 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java x: 1 commits (all time) y: 874 lines of code coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 1 commits (all time) y: 1460 lines of code core/src/main/java/kafka/log/remote/RemoteLogManager.java x: 1 commits (all time) y: 1667 lines of code core/src/main/java/kafka/server/share/SharePartition.java x: 1 commits (all time) y: 1802 lines of code core/src/main/java/kafka/server/share/SharePartitionManager.java x: 1 commits (all time) y: 615 lines of code core/src/main/scala/kafka/cluster/Partition.scala x: 1 commits (all time) y: 1310 lines of code core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala x: 1 commits (all time) y: 1482 lines of code core/src/main/scala/kafka/log/LogCleaner.scala x: 1 commits (all time) y: 759 lines of code core/src/main/scala/kafka/network/SocketServer.scala x: 1 commits (all time) y: 1254 lines of code core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 1 commits (all time) y: 675 lines of code core/src/main/scala/kafka/server/ControllerApis.scala x: 1 commits (all time) y: 977 lines of code core/src/main/scala/kafka/server/KafkaApis.scala x: 1 commits (all time) y: 2916 lines of code core/src/main/scala/kafka/server/ReplicaManager.scala x: 1 commits (all time) y: 2100 lines of code generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java x: 1 commits (all time) y: 1611 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 1 commits (all time) y: 1064 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 1 commits (all time) y: 4156 lines of code metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 1 commits (all time) y: 1969 lines of code raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 1 commits (all time) y: 3047 lines of code streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 1 commits (all time) y: 1398 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 1 commits (all time) y: 1338 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 1 commits (all time) y: 1856 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 1 commits (all time) y: 1299 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 1 commits (all time) y: 1267 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 1 commits (all time) y: 1714 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java x: 1 commits (all time) y: 1435 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java x: 1 commits (all time) y: 793 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 1 commits (all time) y: 858 lines of code webhook-receive.py x: 5 commits (all time) y: 43 lines of code
4156.0
lines of code
  min: 1.0
  average: 111.74
  25th percentile: 17.0
  median: 46.0
  75th percentile: 110.0
  max: 4156.0
0 5.0
commits (all time)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 5.0

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

clients/src/main/java/org/apache/kafka/clients/ApiVersions.java x: 1 contributors (all time) y: 35 lines of code clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java x: 1 contributors (all time) y: 17 lines of code clients/src/main/java/org/apache/kafka/clients/ClientRequest.java x: 1 contributors (all time) y: 77 lines of code clients/src/main/java/org/apache/kafka/clients/ClientResponse.java x: 1 contributors (all time) y: 109 lines of code clients/src/main/java/org/apache/kafka/clients/ClientUtils.java x: 1 contributors (all time) y: 224 lines of code clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java x: 1 contributors (all time) y: 302 lines of code clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 1 contributors (all time) y: 238 lines of code clients/src/main/java/org/apache/kafka/clients/ConnectionState.java x: 1 contributors (all time) y: 10 lines of code clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java x: 1 contributors (all time) y: 406 lines of code clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java x: 1 contributors (all time) y: 96 lines of code clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 1 contributors (all time) y: 525 lines of code clients/src/main/java/org/apache/kafka/clients/MetadataSnapshot.java x: 1 contributors (all time) y: 178 lines of code clients/src/main/java/org/apache/kafka/clients/NetworkClient.java x: 1 contributors (all time) y: 1124 lines of code clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionSpec.java x: 1 contributors (all time) y: 57 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java x: 1 contributors (all time) y: 154 lines of code clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 1 contributors (all time) y: 247 lines of code clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 1 contributors (all time) y: 4063 lines of code clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java x: 1 contributors (all time) y: 133 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java x: 1 contributors (all time) y: 355 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java x: 1 contributors (all time) y: 199 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java x: 1 contributors (all time) y: 325 lines of code clients/src/main/java/org/apache/kafka/clients/admin/internals/ListOffsetsHandler.java x: 1 contributors (all time) y: 185 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 1 contributors (all time) y: 559 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java x: 1 contributors (all time) y: 123 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 1 contributors (all time) y: 285 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java x: 1 contributors (all time) y: 1169 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractHeartbeatRequestManager.java x: 1 contributors (all time) y: 328 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java x: 1 contributors (all time) y: 745 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java x: 1 contributors (all time) y: 1024 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 1 contributors (all time) y: 1539 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 1 contributors (all time) y: 989 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 1 contributors (all time) y: 947 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 1 contributors (all time) y: 1150 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java x: 1 contributors (all time) y: 446 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java x: 1 contributors (all time) y: 596 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 1 contributors (all time) y: 958 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java x: 1 contributors (all time) y: 842 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java x: 1 contributors (all time) y: 804 lines of code clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java x: 1 contributors (all time) y: 498 lines of code clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 1 contributors (all time) y: 825 lines of code clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java x: 1 contributors (all time) y: 430 lines of code clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 1 contributors (all time) y: 511 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java x: 1 contributors (all time) y: 373 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 1 contributors (all time) y: 785 lines of code clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 1 contributors (all time) y: 1369 lines of code clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java x: 1 contributors (all time) y: 417 lines of code clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java x: 1 contributors (all time) y: 1043 lines of code clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java x: 1 contributors (all time) y: 263 lines of code clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java x: 1 contributors (all time) y: 697 lines of code clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java x: 1 contributors (all time) y: 910 lines of code clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java x: 1 contributors (all time) y: 464 lines of code clients/src/main/java/org/apache/kafka/common/record/DefaultRecordBatch.java x: 1 contributors (all time) y: 540 lines of code clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java x: 1 contributors (all time) y: 648 lines of code clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java x: 1 contributors (all time) y: 383 lines of code clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java x: 1 contributors (all time) y: 482 lines of code clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java x: 1 contributors (all time) y: 669 lines of code clients/src/main/java/org/apache/kafka/common/utils/LogContext.java x: 1 contributors (all time) y: 631 lines of code clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 1 contributors (all time) y: 924 lines of code connect/api/src/main/java/org/apache/kafka/connect/data/Values.java x: 1 contributors (all time) y: 1048 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 1 contributors (all time) y: 1669 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 1 contributors (all time) y: 732 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java x: 1 contributors (all time) y: 573 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 1 contributors (all time) y: 2305 lines of code connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java x: 1 contributors (all time) y: 874 lines of code coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 1 contributors (all time) y: 1460 lines of code core/src/main/java/kafka/log/remote/RemoteLogManager.java x: 1 contributors (all time) y: 1667 lines of code core/src/main/java/kafka/server/share/SharePartition.java x: 1 contributors (all time) y: 1802 lines of code core/src/main/java/kafka/server/share/SharePartitionManager.java x: 1 contributors (all time) y: 615 lines of code core/src/main/scala/kafka/cluster/Partition.scala x: 1 contributors (all time) y: 1310 lines of code core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala x: 1 contributors (all time) y: 1482 lines of code core/src/main/scala/kafka/log/LogCleaner.scala x: 1 contributors (all time) y: 759 lines of code core/src/main/scala/kafka/network/SocketServer.scala x: 1 contributors (all time) y: 1254 lines of code core/src/main/scala/kafka/server/AbstractFetcherThread.scala x: 1 contributors (all time) y: 675 lines of code core/src/main/scala/kafka/server/ControllerApis.scala x: 1 contributors (all time) y: 977 lines of code core/src/main/scala/kafka/server/KafkaApis.scala x: 1 contributors (all time) y: 2916 lines of code core/src/main/scala/kafka/server/ReplicaManager.scala x: 1 contributors (all time) y: 2100 lines of code generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java x: 1 contributors (all time) y: 1611 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 1 contributors (all time) y: 1064 lines of code group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 1 contributors (all time) y: 4156 lines of code metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 1 contributors (all time) y: 1969 lines of code raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 1 contributors (all time) y: 3047 lines of code streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 1 contributors (all time) y: 1398 lines of code streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 1 contributors (all time) y: 1338 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 1 contributors (all time) y: 1856 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 1 contributors (all time) y: 1299 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 1 contributors (all time) y: 1267 lines of code streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 1 contributors (all time) y: 1714 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java x: 1 contributors (all time) y: 1435 lines of code streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java x: 1 contributors (all time) y: 793 lines of code streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 1 contributors (all time) y: 858 lines of code
4156.0
lines of code
  min: 1.0
  average: 111.74
  25th percentile: 17.0
  median: 46.0
  75th percentile: 110.0
  max: 4156.0
0 1.0
contributors (all time)
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

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

No data for "commits (30d)" vs. "lines of code".

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

No data for "contributors (30d)" vs. "lines of code".

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

No data for "commits (90d)" vs. "lines of code".

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

No data for "contributors (90d)" vs. "lines of code".