apache / kafka-merge-queue-sandbox
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 3,485 files with 389,399 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 0 files changed 6-20 times (0 lines of code)
    • 3,485 files changed 1-5 times (389,399 lines of code)
0% | 0% | 0% | 0% | 100%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 3,485 files with 389,399 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 0 files changed by 2-5 contributors (0 lines of code)
    • 3,485 files changed by 1 contributor (389,399 lines of code)
0% | 0% | 0% | 0% | 100%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, scala, json, html, sh, yaml, bat, py, properties, xml, md, gitignore, txt, gradle, svg, js, xsl, awk, rdf
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 0% | 100%
scala0% | 0% | 0% | 0% | 100%
py0% | 0% | 0% | 0% | 100%
xml0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
xsl0% | 0% | 0% | 0% | 100%
rdf0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
awk0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
clients0% | 0% | 0% | 0% | 100%
streams0% | 0% | 0% | 0% | 100%
connect0% | 0% | 0% | 0% | 100%
core0% | 0% | 0% | 0% | 100%
metadata0% | 0% | 0% | 0% | 100%
tools0% | 0% | 0% | 0% | 100%
group-coordinator0% | 0% | 0% | 0% | 100%
raft0% | 0% | 0% | 0% | 100%
storage0% | 0% | 0% | 0% | 100%
server-common0% | 0% | 0% | 0% | 100%
trogdor0% | 0% | 0% | 0% | 100%
generator0% | 0% | 0% | 0% | 100%
jmh-benchmarks0% | 0% | 0% | 0% | 100%
server0% | 0% | 0% | 0% | 100%
coordinator-common0% | 0% | 0% | 0% | 100%
share-coordinator0% | 0% | 0% | 0% | 100%
shell0% | 0% | 0% | 0% | 100%
release0% | 0% | 0% | 0% | 100%
gradle0% | 0% | 0% | 0% | 100%
committer-tools0% | 0% | 0% | 0% | 100%
transaction-coordinator0% | 0% | 0% | 0% | 100%
docker0% | 0% | 0% | 0% | 100%
config0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
test-common0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
43 - 2024-08-16 2024-08-26 4 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/clients/producer
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/clients/admin
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/server/telemetry
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/server/policy
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/server/authorizer
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/server/quota
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/requests
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/network
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/errors
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/record
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/serialization
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/replica
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/resource
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/protocol
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/protocol/types
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/feature
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/security
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/security/auth
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/security/plain
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/security/token/delegation
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/security/oauthbearer
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/security/kerberos
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/security/scram
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/security/ssl
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/security/authenticator
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/config
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/config/types
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/config/provider
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/header
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/annotation
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/memory
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/utils
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/acl
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/compress
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/quota
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/metrics
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in clients/src/main/java/org/apache/kafka/common/metrics/stats
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
print.awk
in root
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in streams/src/main/java/org/apache/kafka/streams
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in streams/src/main/java/org/apache/kafka/streams/kstream
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in streams/src/main/java/org/apache/kafka/streams/errors
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in streams/src/main/java/org/apache/kafka/streams/processor
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in streams/src/main/java/org/apache/kafka/streams/processor/api
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in streams/src/main/java/org/apache/kafka/streams/processor/assignment
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in streams/src/main/java/org/apache/kafka/streams/processor/assignment/assignors
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in streams/src/main/java/org/apache/kafka/streams/query
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
package-info.java
in streams/src/main/java/org/apache/kafka/streams/state
 1 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
43 - 2024-08-16 2024-08-26 4 1 mumrah@gmail.com mumrah@gmail.com
xsl
rat-output-to-html.xsl
in gradle/resources
 153 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
16 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
343 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
DirectoryId.java
in server-common/src/main/java/org/apache/kafka/common
 60 4 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ClientIdAndBroker.java
in server-common/src/main/java/org/apache/kafka/common
 15 2 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
AssignmentsHelper.java
in server-common/src/main/java/org/apache/kafka/metadata
 80 4 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
AdminUtils.java
in server-common/src/main/java/org/apache/kafka/admin
 136 2 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
BrokerMetadata.java
in server-common/src/main/java/org/apache/kafka/admin
 22 3 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
DeferredEvent.java
in server-common/src/main/java/org/apache/kafka/deferred
 4 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
DeferredEventQueue.java
in server-common/src/main/java/org/apache/kafka/deferred
 69 5 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
FilteringJmxReporter.java
in server-common/src/main/java/org/apache/kafka/server/metrics
 32 3 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
KafkaMetricsGroup.java
in server-common/src/main/java/org/apache/kafka/server/metrics
 119 20 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
KafkaYammerMetrics.java
in server-common/src/main/java/org/apache/kafka/server/metrics
 132 10 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
DelayedOperationKey.java
in server-common/src/main/java/org/apache/kafka/server/purgatory
 4 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
DelayedOperationPurgatory.java
in server-common/src/main/java/org/apache/kafka/server/purgatory
 255 22 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
DelayedOperation.java
in server-common/src/main/java/org/apache/kafka/server/purgatory
 65 8 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
TopicPartitionOperationKey.java
in server-common/src/main/java/org/apache/kafka/server/purgatory
 33 6 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
GroupJoinKey.java
in server-common/src/main/java/org/apache/kafka/server/purgatory
 23 4 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
MemberKey.java
in server-common/src/main/java/org/apache/kafka/server/purgatory
 25 4 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
GroupSyncKey.java
in server-common/src/main/java/org/apache/kafka/server/purgatory
 23 4 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
QuotaType.java
in server-common/src/main/java/org/apache/kafka/server/quota
 29 2 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
SensorAccess.java
in server-common/src/main/java/org/apache/kafka/server/quota
 35 2 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
QuotaUtils.java
in server-common/src/main/java/org/apache/kafka/server/quota
 26 4 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
TopicOptionalIdPartition.java
in server-common/src/main/java/org/apache/kafka/server/common
 51 8 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
FeatureVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 8 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
EligibleLeaderReplicasVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 50 6 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
RequestLocal.java
in server-common/src/main/java/org/apache/kafka/server/common
 38 8 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
AdminCommandFailedException.java
in server-common/src/main/java/org/apache/kafka/server/common
 9 2 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
GroupVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 50 6 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
KRaftVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 75 9 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
MetadataVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 256 36 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
FinalizedFeatures.java
in server-common/src/main/java/org/apache/kafka/server/common
 24 1 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
DirectoryEventHandler.java
in server-common/src/main/java/org/apache/kafka/server/common
 10 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
TestFeatureVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 31 4 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
UnitTestFeatureVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 245 32 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
OffsetAndEpoch.java
in server-common/src/main/java/org/apache/kafka/server/common
 32 6 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
CheckpointFile.java
in server-common/src/main/java/org/apache/kafka/server/common
 138 9 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
StopPartition.java
in server-common/src/main/java/org/apache/kafka/server/common
 38 4 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
TopicIdPartition.java
in server-common/src/main/java/org/apache/kafka/server/common
 11 1 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
NodeToControllerChannelManager.java
in server-common/src/main/java/org/apache/kafka/server/common
 14 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ControllerRequestCompletionHandler.java
in server-common/src/main/java/org/apache/kafka/server/common
 5 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
Feature.java
in server-common/src/main/java/org/apache/kafka/server/common
 187 14 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ApiMessageAndVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 33 6 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
MetadataParseException.java
in server-common/src/main/java/org/apache/kafka/server/common/serialization
 13 3 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
RecordSerde.java
in server-common/src/main/java/org/apache/kafka/server/common/serialization
 9 - 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
AbstractApiMessageSerde.java
in server-common/src/main/java/org/apache/kafka/server/common/serialization
 72 4 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
BytesApiMessageSerde.java
in server-common/src/main/java/org/apache/kafka/server/common/serialization
 27 2 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ProducerIdsBlock.java
in server-common/src/main/java/org/apache/kafka/server/common
 59 10 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
AdminOperationException.java
in server-common/src/main/java/org/apache/kafka/server/common
 9 2 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
GroupMetadataManager.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 4156 185 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4063 149 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
KafkaRaftClient.java
in raft/src/main/java/org/apache/kafka/raft
 3047 149 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
KafkaApis.scala
in core/src/main/scala/kafka/server
 2916 86 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 2305 127 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2100 83 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ReplicationControlManager.java
in metadata/src/main/java/org/apache/kafka/controller
 1969 79 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
InternalTopologyBuilder.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1856 159 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
SharePartition.java
in core/src/main/java/kafka/server/share
 1802 98 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
TaskManager.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1714 116 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
QuorumController.java
in metadata/src/main/java/org/apache/kafka/controller
 1671 111 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
Worker.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1669 90 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
RemoteLogManager.java
in core/src/main/java/kafka/log/remote
 1667 111 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
MessageDataGenerator.java
in generator/src/main/java/org/apache/kafka/message
 1611 51 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
AsyncKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1539 97 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
GroupCoordinator.scala
in core/src/main/scala/kafka/coordinator/group
 1482 66 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
CoordinatorRuntime.java
in coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime
 1460 83 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 1435 302 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
KafkaStreams.java
in streams/src/main/java/org/apache/kafka/streams
 1398 81 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
TransactionManager.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 1369 129 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
StreamsConfig.java
in streams/src/main/java/org/apache/kafka/streams
 1338 49 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
UnifiedLog.scala
in core/src/main/scala/kafka/log
 1321 87 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
Partition.scala
in core/src/main/scala/kafka/cluster
 1310 75 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
StreamThread.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1299 60 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
StreamsPartitionAssignor.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1267 49 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
SocketServer.scala
in core/src/main/scala/kafka/network
 1254 88 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
AbstractCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1169 84 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ConsumerGroupCommand.java
in tools/src/main/java/org/apache/kafka/tools/consumer/group
 1166 44 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
KTableImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1162 68 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ConsumerCoordinator.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1150 55 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
LogManager.scala
in core/src/main/scala/kafka/log
 1128 60 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
NetworkClient.java
in clients/src/main/java/org/apache/kafka/clients
 1124 87 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
GroupCoordinatorService.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 1064 41 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
KStreamImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 1062 81 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
Values.java
in connect/api/src/main/java/org/apache/kafka/connect/data
 1048 73 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ConfigDef.java
in clients/src/main/java/org/apache/kafka/common/config
 1043 104 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
Selector.java
in clients/src/main/java/org/apache/kafka/common/network
 1030 80 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ReassignPartitionsCommand.java
in tools/src/main/java/org/apache/kafka/tools/reassign
 1027 35 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
AbstractStickyAssignor.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1024 49 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
StreamTask.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1023 69 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
AbstractHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 1021 66 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ClassicKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 989 67 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
PersisterStateManager.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 978 64 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ControllerApis.scala
in core/src/main/scala/kafka/server
 977 44 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
ShareConsumeRequestManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 958 53 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
DefaultStateUpdater.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 954 77 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
SubscriptionState.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 954 143 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
CommitRequestManager.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 947 60 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
Utils.java
in clients/src/main/java/org/apache/kafka/common/utils
 924 89 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
GroupMetadataManager.scala
in core/src/main/scala/kafka/coordinator/group
 916 43 2025-02-05 2025-02-05 1 1 mumrah@gmail.com mumrah@gmail.com
Correlations

File Size vs. Number of Changes: 3485 points

clients/src/main/java/org/apache/kafka/clients/ApiVersions.java x: 35 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java x: 17 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/ClientRequest.java x: 77 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/ClientResponse.java x: 109 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/ClientUtils.java x: 224 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java x: 302 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java x: 238 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/ConnectionState.java x: 10 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/FetchSessionHandler.java x: 406 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/GroupRebalanceConfig.java x: 69 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/HostResolver.java x: 6 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/InFlightRequests.java x: 96 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/ManualMetadataUpdater.java x: 45 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/Metadata.java x: 525 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/MetadataSnapshot.java x: 178 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/MetadataUpdater.java x: 24 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/NetworkClient.java x: 1124 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/NodeApiVersions.java x: 170 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/AbortTransactionSpec.java x: 57 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/Admin.java x: 310 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/AlterConfigOp.java x: 61 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java x: 51 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupDescription.java x: 154 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/ConsumerGroupListing.java x: 85 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java x: 247 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java x: 4063 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/MemberDescription.java x: 133 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/NewTopic.java x: 100 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/AbortTransactionHandler.java x: 144 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminApiDriver.java x: 355 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/AdminMetadataManager.java x: 199 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/AlterConsumerGroupOffsetsHandler.java x: 160 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/DescribeConsumerGroupsHandler.java x: 325 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/FenceProducersHandler.java x: 113 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/admin/internals/ListOffsetsHandler.java x: 185 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerConfig.java x: 559 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerPartitionAssignor.java x: 195 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/ConsumerRecord.java x: 123 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java x: 285 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java x: 535 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java x: 1169 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java x: 300 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractMembershipManager.java x: 745 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractStickyAssignor.java x: 1024 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java x: 1539 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java x: 989 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java x: 947 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java x: 1150 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerHeartbeatRequestManager.java x: 211 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java x: 446 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/FetchMetricsManager.java x: 230 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java x: 345 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetFetcherUtils.java x: 331 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/OffsetsRequestManager.java x: 596 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestFuture.java x: 136 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManagers.java x: 286 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java x: 958 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java x: 842 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsMembershipManager.java x: 804 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java x: 498 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java x: 825 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/producer/MockProducer.java x: 430 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/producer/ProducerConfig.java x: 511 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/ProducerBatch.java x: 373 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/RecordAccumulator.java x: 737 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java x: 785 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java x: 1369 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/compress/Lz4BlockInputStream.java x: 209 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/compress/Lz4BlockOutputStream.java x: 249 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/config/AbstractConfig.java x: 417 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/config/ConfigDef.java x: 1043 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/metrics/JmxReporter.java x: 263 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/network/Selector.java x: 1030 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java x: 697 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/protocol/Errors.java x: 493 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/protocol/types/Type.java x: 910 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/record/AbstractLegacyRecordBatch.java x: 464 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/record/DefaultRecord.java x: 401 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/record/MemoryRecords.java x: 648 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/record/MemoryRecordsBuilder.java x: 567 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java x: 256 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java x: 383 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/requests/LeaderAndIsrRequest.java x: 321 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/requests/MetadataResponse.java x: 378 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java x: 530 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java x: 482 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java x: 392 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java x: 669 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/utils/LogContext.java x: 631 lines of code y: 1 # changes clients/src/main/java/org/apache/kafka/common/utils/Utils.java x: 924 lines of code y: 1 # changes connect/json/src/main/java/org/apache/kafka/connect/json/JsonConverter.java x: 623 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java x: 590 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/SourceConnectorConfig.java x: 273 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java x: 1669 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerConnector.java x: 472 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerSinkTask.java x: 732 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java x: 346 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedConfig.java x: 573 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java x: 2305 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java x: 505 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaConfigBackingStore.java x: 874 lines of code y: 1 # changes connect/runtime/src/main/java/org/apache/kafka/connect/storage/KafkaStatusBackingStore.java x: 551 lines of code y: 1 # changes coordinator-common/src/main/java/org/apache/kafka/coordinator/common/runtime/CoordinatorRuntime.java x: 1460 lines of code y: 1 # changes core/src/main/java/kafka/server/share/SharePartition.java x: 1802 lines of code y: 1 # changes core/src/main/java/kafka/server/share/SharePartitionManager.java x: 615 lines of code y: 1 # changes core/src/main/scala/kafka/cluster/Partition.scala x: 1310 lines of code y: 1 # changes core/src/main/scala/kafka/coordinator/group/GroupCoordinator.scala x: 1482 lines of code y: 1 # changes core/src/main/scala/kafka/coordinator/group/GroupMetadataManager.scala x: 916 lines of code y: 1 # changes core/src/main/scala/kafka/coordinator/transaction/TransactionMarkerChannelManager.scala x: 366 lines of code y: 1 # changes core/src/main/scala/kafka/log/LogCleaner.scala x: 759 lines of code y: 1 # changes core/src/main/scala/kafka/log/LogManager.scala x: 1128 lines of code y: 1 # changes core/src/main/scala/kafka/log/UnifiedLog.scala x: 1321 lines of code y: 1 # changes core/src/main/scala/kafka/network/SocketServer.scala x: 1254 lines of code y: 1 # changes core/src/main/scala/kafka/raft/KafkaMetadataLog.scala x: 543 lines of code y: 1 # changes core/src/main/scala/kafka/server/BrokerServer.scala x: 644 lines of code y: 1 # changes core/src/main/scala/kafka/server/ControllerApis.scala x: 977 lines of code y: 1 # changes core/src/main/scala/kafka/server/DynamicBrokerConfig.scala x: 830 lines of code y: 1 # changes core/src/main/scala/kafka/server/FetchSession.scala x: 581 lines of code y: 1 # changes core/src/main/scala/kafka/server/KafkaApis.scala x: 2916 lines of code y: 1 # changes core/src/main/scala/kafka/server/ReplicaManager.scala x: 2100 lines of code y: 1 # changes generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java x: 1611 lines of code y: 1 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorConfig.java x: 424 lines of code y: 1 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java x: 1064 lines of code y: 1 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java x: 4156 lines of code y: 1 # changes group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java x: 754 lines of code y: 1 # changes jmh-benchmarks/src/main/java/org/apache/kafka/jmh/util/ByteUtilsBenchmark.java x: 452 lines of code y: 1 # changes metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java x: 1969 lines of code y: 1 # changes raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java x: 3047 lines of code y: 1 # changes raft/src/main/java/org/apache/kafka/raft/QuorumState.java x: 720 lines of code y: 1 # changes raft/src/main/java/org/apache/kafka/raft/RaftUtil.java x: 663 lines of code y: 1 # changes server/src/main/java/org/apache/kafka/network/RequestConvertToJson.java x: 778 lines of code y: 1 # changes share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java x: 622 lines of code y: 1 # changes storage/src/main/java/org/apache/kafka/server/log/remote/metadata/storage/TopicBasedRemoteLogMetadataManager.java x: 440 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java x: 1398 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java x: 1338 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableImpl.java x: 1162 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java x: 1856 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java x: 473 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java x: 1299 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java x: 1267 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java x: 1714 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapter.java x: 1435 lines of code y: 1 # changes streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java x: 793 lines of code y: 1 # changes streams/test-utils/src/main/java/org/apache/kafka/streams/TopologyTestDriver.java x: 858 lines of code y: 1 # changes tools/src/main/java/org/apache/kafka/tools/ReplicaVerificationTool.java x: 602 lines of code y: 1 # changes tools/src/main/java/org/apache/kafka/tools/TopicCommand.java x: 836 lines of code y: 1 # changes webhook-receive.py x: 43 lines of code y: 4 # changes
4.0
# changes
  min: 1.0
  average: 1.0
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 4.0
0 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

Number of Contributors vs. Number of Changes: 3485 points

clients/src/main/java/org/apache/kafka/clients/ApiVersions.java x: 1 # contributors y: 1 # changes webhook-receive.py x: 1 # contributors y: 4 # changes
4.0
# changes
  min: 1.0
  average: 1.0
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 4.0
0 1.0
# contributors
min: 1.0 | average: 1.0 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 1.0 | max: 1.0

Number of Contributors vs. File Size: 3485 points

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