apache / kafka
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 3,535 files with 397,157 lines of code in files.
    • 2,873 files that are 366+ days old (329,751 lines of code)
    • 381 files that are 181-365 days old (43,544 lines of code)
    • 175 files that are 91-180 days old (14,137 lines of code)
    • 64 files that are 31-90 days old (5,003 lines of code)
    • 42 files that are 1-30 days old (4,722 lines of code)
83% | 10% | 3% | 1% | 1%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 3,535 files with 397,157 lines of code in files.
    • 986 files have been last changed 366+ days ago (31,924 lines of code)
    • 822 files have been last changed 181-365 days ago (70,801 lines of code)
    • 611 files have been last changed 91-180 days ago (81,425 lines of code)
    • 651 files have been last changed 31-90 days ago (77,236 lines of code)
    • 465 files have been last changed 1-30 days ago (135,771 lines of code)
8% | 17% | 20% | 19% | 34%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, scala, json, py, yaml, html, sh, properties, bat, xml, md, gitignore, txt, gradle, cfg, svg, js, xsl, in, rdf, pub
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java82% | 11% | 3% | 1% | 1%
scala99% | 0% | <1% | <1% | 0%
xml100% | 0% | 0% | 0% | 0%
xsl100% | 0% | 0% | 0% | 0%
py4% | 89% | 0% | 6% | 0%
rdf100% | 0% | 0% | 0% | 0%
html100% | 0% | 0% | 0% | 0%
yaml0% | 0% | 100% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java8% | 19% | 21% | 19% | 31%
scala3% | 1% | 6% | 17% | 70%
xsl100% | 0% | 0% | 0% | 0%
xml4% | 0% | 4% | 91% | 0%
html100% | 0% | 0% | 0% | 0%
py0% | 38% | 22% | 15% | 22%
rdf0% | 100% | 0% | 0% | 0%
yaml0% | 0% | 46% | 0% | 53%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
clients84% | 10% | 2% | 2% | <1%
streams96% | 3% | <1% | <1% | <1%
connect98% | 1% | <1% | 0% | <1%
core86% | 11% | <1% | <1% | <1%
metadata92% | 5% | <1% | 1% | <1%
tools76% | 12% | 8% | <1% | 2%
group-coordinator57% | 25% | 14% | 3% | <1%
raft82% | 13% | 2% | <1% | <1%
storage55% | 21% | <1% | 5% | 16%
trogdor89% | 4% | 5% | 0% | 0%
server-common56% | 11% | 28% | <1% | 1%
generator83% | 10% | 6% | 0% | 0%
jmh-benchmarks71% | 19% | 9% | 0% | 0%
shell100% | 0% | 0% | 0% | 0%
server34% | 34% | 15% | 5% | 9%
gradle100% | 0% | 0% | 0% | 0%
transaction-coordinator42% | 41% | 6% | 9% | 0%
docker34% | 65% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
coordinator-common0% | 95% | 4% | 0% | 0%
share-coordinator0% | 92% | 7% | 0% | 0%
release0% | 100% | 0% | 0% | 0%
committer-tools0% | 84% | 0% | 15% | 0%
config0% | 0% | 100% | 0% | 0%
test-common0% | 0% | 100% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
clients10% | 20% | 18% | 18% | 32%
streams11% | 19% | 35% | 21% | 12%
connect9% | 24% | 21% | 3% | 41%
metadata8% | 11% | 8% | 47% | 23%
storage7% | 6% | 10% | 37% | 37%
server-common11% | 17% | 17% | 20% | 32%
generator16% | 22% | 53% | 8% | 0%
trogdor9% | 57% | 28% | 3% | 0%
core1% | 1% | 4% | 18% | 74%
raft3% | 5% | 10% | 16% | 64%
tools1% | 23% | 24% | 13% | 37%
shell11% | 29% | 49% | 9% | 0%
server3% | 6% | 6% | 46% | 36%
gradle30% | 0% | 3% | 66% | 0%
group-coordinator<1% | 2% | 8% | 23% | 65%
jmh-benchmarks0% | 41% | 23% | 18% | 17%
coordinator-common0% | 15% | 16% | 12% | 54%
release0% | 46% | 2% | 0% | 50%
transaction-coordinator0% | 66% | 6% | 27% | 0%
docker0% | 83% | 0% | 16% | 0%
committer-tools0% | 19% | 49% | 31% | 0%
share-coordinator0% | 1% | 12% | 6% | 79%
ROOT0% | 100% | 0% | 0% | 0%
config0% | 0% | 27% | 0% | 72%
test-common0% | 0% | 100% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
Partition.scala
in core/src/main/scala/kafka/cluster
 1320 75 2011-08-10 2025-05-01 292 92 hsaputra@apache.org 79797958+mirai1129@users.no...
SocketServer.scala
in core/src/main/scala/kafka/network
 1249 87 2011-08-10 2025-04-30 200 84 hsaputra@apache.org payang@apache.org
LogManager.scala
in core/src/main/scala/kafka/log
 1098 58 2011-08-10 2025-04-27 232 87 hsaputra@apache.org payang@apache.org
KafkaConfig.scala
in core/src/main/scala/kafka/server
 607 24 2011-08-10 2025-04-30 466 172 hsaputra@apache.org payang@apache.org
Kafka.scala
in core/src/main/scala/kafka
 75 3 2011-08-10 2025-01-06 47 32 junrao@apache.org mimaison@users.noreply.gith...
Annotations.scala
in core/src/main/scala/kafka/utils
 5 - 2011-08-10 2017-03-30 3 3 hsaputra@apache.org vahidhashemian@us.ibm.com
DumpLogSegments.scala
in core/src/main/scala/kafka/tools
 566 26 2011-08-23 2025-03-13 121 55 nehanarkhede@apache.org mimaison@users.noreply.gith...
Mx4jLoader.scala
in core/src/main/scala/kafka/utils
 37 1 2011-10-06 2023-10-17 14 10 junrao@apache.org mimaison@users.noreply.gith...
Logging.scala
in core/src/main/scala/kafka/utils
 43 1 2011-11-23 2025-02-06 19 13 jkreps@apache.org piotr@github.copernik.eu
KafkaApis.scala
in core/src/main/scala/kafka/server
 3343 94 2012-01-13 2025-05-01 615 148 nehanarkhede@apache.org cwadhwa@confluent.io
RequestChannel.scala
in core/src/main/scala/kafka/network
 372 15 2012-01-13 2025-04-12 158 60 nehanarkhede@apache.org parkerhiphop027@gmail.com
KafkaRequestHandler.scala
in core/src/main/scala/kafka/server
 168 10 2012-01-13 2025-04-12 83 40 nehanarkhede@apache.org parkerhiphop027@gmail.com
Replica.scala
in core/src/main/scala/kafka/cluster
 119 4 2012-03-21 2025-03-17 54 24 nehanarkhede@apache.org payang@apache.org
ReplicaManager.scala
in core/src/main/scala/kafka/server
 2203 86 2012-03-23 2025-04-29 444 123 nehanarkhede@apache.org o.g.h.ibrahim@gmail.com
ReplicaFetcherThread.scala
in core/src/main/scala/kafka/server
 120 11 2012-06-01 2025-04-01 164 72 nehanarkhede@apache.org ismael@juma.me.uk
AbstractFetcherThread.scala
in core/src/main/scala/kafka/server
 680 37 2012-06-23 2025-05-01 157 70 junrao@apache.org 79797958+mirai1129@users.no...
AbstractFetcherManager.scala
in core/src/main/scala/kafka/server
 184 16 2012-06-23 2025-04-27 53 29 junrao@apache.org payang@apache.org
ReplicaFetcherManager.scala
in core/src/main/scala/kafka/server
 37 2 2012-06-23 2025-04-01 28 19 junrao@apache.org ismael@juma.me.uk
KafkaCSVMetricsReporter.scala
in core/src/main/scala/kafka/metrics
 52 3 2012-08-16 2022-08-24 17 12 jjkoshy@apache.org matthew.dedetrich@aiven.io
KafkaMetricsReporter.scala
in core/src/main/scala/kafka/metrics
 39 3 2012-08-16 2025-03-12 14 12 jjkoshy@apache.org mimaison@users.noreply.gith...
KafkaMetricsConfig.scala
in core/src/main/scala/kafka/metrics
 12 - 2012-08-16 2024-05-23 10 8 jjkoshy@apache.org mimaison@users.noreply.gith...
VerifiableProperties.scala
in core/src/main/scala/kafka/utils
 112 12 2012-08-25 2024-02-09 25 18 junrao@apache.org dct012@gmail.com
package.html
in core/src/main/scala/kafka/log
 4 - 2012-12-02 2018-04-11 4 4 jkreps@apache.org jimin.hsieh.engineer@gmail.com
ConfigDef.java
in clients/src/main/java/org/apache/kafka/common/config
 1043 104 2014-02-07 2024-11-22 80 53 junrao@gmail.com mimaison@users.noreply.gith...
Selector.java
in clients/src/main/java/org/apache/kafka/common/network
 1030 80 2014-02-07 2024-11-06 107 55 junrao@gmail.com yungyung7654321@gmail.com
Utils.java
in clients/src/main/java/org/apache/kafka/common/utils
 924 89 2014-02-07 2025-04-29 149 90 junrao@gmail.com o.g.h.ibrahim@gmail.com
Type.java
in clients/src/main/java/org/apache/kafka/common/protocol/types
 910 138 2014-02-07 2024-09-08 29 23 jay.kreps@gmail.com ivan@ivanyu.me
KafkaProducer.java
in clients/src/main/java/org/apache/kafka/clients/producer
 831 47 2014-02-07 2025-04-24 242 118 junrao@gmail.com 98577846+rreddy-22@users.no...
Sender.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 796 41 2014-02-07 2025-04-29 151 54 jay.kreps@gmail.com o.g.h.ibrahim@gmail.com
RecordAccumulator.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 731 53 2014-02-07 2025-04-11 114 55 junrao@gmail.com jhenyunghsu@gmail.com
MemoryRecords.java
in clients/src/main/java/org/apache/kafka/common/record
 639 66 2014-02-07 2025-03-05 77 34 junrao@gmail.com dengziming1993@gmail.com
ProducerConfig.java
in clients/src/main/java/org/apache/kafka/clients/producer
 528 11 2014-02-07 2025-04-24 137 73 junrao@gmail.com 98577846+rreddy-22@users.no...
Errors.java
in clients/src/main/java/org/apache/kafka/common/protocol
 492 12 2014-02-07 2025-05-06 129 61 junrao@gmail.com aschofield@confluent.io
Struct.java
in clients/src/main/java/org/apache/kafka/common/protocol/types
 432 85 2014-02-07 2022-05-25 41 24 junrao@gmail.com dengziming1993@gmail.com
MockProducer.java
in clients/src/main/java/org/apache/kafka/clients/producer
 431 43 2014-02-07 2025-04-24 57 41 junrao@gmail.com 98577846+rreddy-22@users.no...
AbstractConfig.java
in clients/src/main/java/org/apache/kafka/common/config
 420 46 2014-02-07 2025-03-23 69 45 junrao@gmail.com tjwu1217@gmail.com
MetadataResponse.java
in clients/src/main/java/org/apache/kafka/common/requests
 378 44 2014-02-07 2025-04-24 62 34 jay.kreps@gmail.com vikas@confluent.io
Metrics.java
in clients/src/main/java/org/apache/kafka/common/metrics
 333 41 2014-02-07 2024-11-03 45 35 junrao@gmail.com 154567180+linsiyuan9@users....
ApiKeys.java
in clients/src/main/java/org/apache/kafka/common/protocol
 284 26 2014-02-07 2025-03-31 136 50 junrao@gmail.com ismael@juma.me.uk
JmxReporter.java
in clients/src/main/java/org/apache/kafka/common/metrics
 263 26 2014-02-07 2024-11-25 30 24 junrao@gmail.com 31186669+clarkwtc@users.nor...
Cluster.java
in clients/src/main/java/org/apache/kafka/common
 243 30 2014-02-07 2024-06-06 39 21 junrao@gmail.com mimaison@users.noreply.gith...
Sensor.java
in clients/src/main/java/org/apache/kafka/common/metrics
 239 26 2014-02-07 2025-01-04 37 22 junrao@gmail.com ismael@juma.me.uk
BufferPool.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 219 16 2014-02-07 2024-11-06 28 21 junrao@gmail.com yungyung7654321@gmail.com
Protocol.java
in clients/src/main/java/org/apache/kafka/common/protocol
 193 6 2014-02-07 2025-02-02 75 33 junrao@gmail.com ismael@juma.me.uk
MetadataRequest.java
in clients/src/main/java/org/apache/kafka/common/requests
 158 21 2014-02-07 2025-03-26 36 21 jay.kreps@gmail.com vikas@confluent.io
Field.java
in clients/src/main/java/org/apache/kafka/common/protocol/types
 146 30 2014-02-07 2022-05-25 15 14 junrao@gmail.com dengziming1993@gmail.com
Schema.java
in clients/src/main/java/org/apache/kafka/common/protocol/types
 143 14 2014-02-07 2024-11-03 17 13 jay.kreps@gmail.com 154567180+linsiyuan9@users....
CompressionType.java
in clients/src/main/java/org/apache/kafka/common/record
 133 15 2014-02-07 2024-08-26 27 19 junrao@gmail.com 422766572@qq.com
Histogram.java
in clients/src/main/java/org/apache/kafka/common/metrics/stats
 127 13 2014-02-07 2024-06-06 9 10 junrao@gmail.com mimaison@users.noreply.gith...
RequestHeader.java
in clients/src/main/java/org/apache/kafka/common/requests
 115 18 2014-02-07 2025-01-20 29 12 junrao@gmail.com ismael@juma.me.uk
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
package.html
in core/src/main/scala/kafka/server
 1 - 2014-02-07 2014-02-24 2 2 junrao@gmail.com sriram.sub@gmail.com
package.html
in core/src/main/scala/kafka/network
 11 - 2014-02-07 2014-02-24 2 2 junrao@gmail.com sriram.sub@gmail.com
xsl
rat-output-to-html.xsl
in gradle/resources
 153 - 2015-07-06 2015-07-06 1 1 me@ewencp.org me@ewencp.org
NoAvailableBrokersException.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 5 - 2015-07-15 2017-02-28 2 2 jason@confluent.io matthias@confluent.io
RequestFutureListener.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 5 - 2015-07-15 2017-02-28 2 2 jason@confluent.io matthias@confluent.io
Configurable.java
in clients/src/main/java/org/apache/kafka/common
 5 - 2014-02-07 2017-02-28 4 5 junrao@gmail.com matthias@confluent.io
KTableValueGetterSupplier.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 5 - 2015-12-04 2017-02-28 3 2 yasuhiro@confluent.io matthias@confluent.io
PeekingKeyValueIterator.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 6 - 2016-09-16 2017-02-28 3 2 damian.guy@gmail.com matthias@confluent.io
HasNextCondition.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 6 - 2017-01-06 2017-02-28 2 2 damian.guy@gmail.com matthias@confluent.io
NotAssignedException.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 6 1 2016-04-18 2017-02-28 2 2 jason@confluent.io matthias@confluent.io
NotLeaderException.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 6 1 2015-11-09 2017-02-28 3 3 me@ewencp.org matthias@confluent.io
RequestFutureAdapter.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 7 1 2015-07-15 2017-02-28 2 2 jason@confluent.io matthias@confluent.io
NotEnoughReplicasAfterAppendException.java
in clients/src/main/java/org/apache/kafka/common/errors
 7 1 2014-10-10 2017-02-28 4 3 cshapi@gmail.com matthias@confluent.io
InvalidRequiredAcksException.java
in clients/src/main/java/org/apache/kafka/common/errors
 7 1 2015-02-13 2017-02-28 2 2 cshapi@gmail.com matthias@confluent.io
NoMatchingRule.java
in clients/src/main/java/org/apache/kafka/common/security/kerberos
 7 - 2015-10-20 2017-02-28 2 2 schintalapani@hortonworks.com matthias@confluent.io
OffsetStorageReader.java
in connect/api/src/main/java/org/apache/kafka/connect/storage
 7 - 2015-11-09 2017-02-28 3 3 me@ewencp.org matthias@confluent.io
StateStoreProvider.java
in streams/src/main/java/org/apache/kafka/streams/state/internals
 8 - 2016-07-19 2017-02-28 3 2 damian.guy@gmail.com matthias@confluent.io
RequestAndSize.java
in clients/src/main/java/org/apache/kafka/common/requests
 9 1 2017-02-17 2017-02-28 2 2 ismael@juma.me.uk matthias@confluent.io
AuthorizationException.java
in clients/src/main/java/org/apache/kafka/common/errors
 9 2 2015-10-29 2017-02-28 4 4 brahmbhatt.parth@gmail.com matthias@confluent.io
PolicyViolationException.java
in clients/src/main/java/org/apache/kafka/common/errors
 9 2 2017-01-14 2017-02-28 3 2 ismael@juma.me.uk matthias@confluent.io
SimpleConfig.java
in connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util
 9 1 2017-01-13 2017-02-28 2 2 shikhar@confluent.io matthias@confluent.io
InvalidOffsetException.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 10 1 2015-11-08 2017-02-28 2 2 jason@confluent.io matthias@confluent.io
InconsistentGroupProtocolException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-01-18 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
InvalidCommitOffsetSizeException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-01-18 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
TopicExistsException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-07-12 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
InvalidConfigurationException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-07-12 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
InvalidTimestampException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-02-19 2017-02-28 2 2 becket.qin@gmail.com matthias@confluent.io
InvalidSessionTimeoutException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-01-18 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
BrokerNotAvailableException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2015-09-02 2017-02-28 2 2 ismael@juma.me.uk matthias@confluent.io
InvalidReplicaAssignmentException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-07-12 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
InvalidGroupIdException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-01-18 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
InvalidRequestException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-07-12 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
ClusterAuthorizationException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-01-07 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
InvalidReplicationFactorException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-07-12 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
LeaderNotAvailableException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2014-02-07 2017-02-28 5 5 junrao@gmail.com matthias@confluent.io
InvalidPartitionsException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-07-12 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
ControllerMovedException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2015-09-02 2017-02-28 2 2 ismael@juma.me.uk matthias@confluent.io
NotControllerException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-07-12 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
InvalidOffsetException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-01-07 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
InvalidFetchSizeException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2016-01-07 2017-02-28 2 2 granthenke@gmail.com matthias@confluent.io
OffsetOutOfRangeException.java
in clients/src/main/java/org/apache/kafka/common/errors
 10 2 2014-02-07 2017-02-28 6 6 junrao@gmail.com matthias@confluent.io
BadFormatString.java
in clients/src/main/java/org/apache/kafka/common/security/kerberos
 10 - 2015-10-30 2017-02-28 2 2 ismael@juma.me.uk matthias@confluent.io
Config.java
in clients/src/main/java/org/apache/kafka/common/config
 11 2 2016-03-17 2017-02-28 3 3 liquanpei@gmail.com matthias@confluent.io
AlreadyExistsException.java
in connect/api/src/main/java/org/apache/kafka/connect/errors
 12 3 2015-11-09 2017-02-28 2 2 me@ewencp.org matthias@confluent.io
IllegalWorkerStateException.java
in connect/api/src/main/java/org/apache/kafka/connect/errors
 12 3 2015-11-09 2017-02-28 2 2 me@ewencp.org matthias@confluent.io
RetriableException.java
in connect/api/src/main/java/org/apache/kafka/connect/errors
 12 3 2015-11-09 2017-02-28 2 2 me@ewencp.org matthias@confluent.io
NotFoundException.java
in connect/api/src/main/java/org/apache/kafka/connect/errors
 12 3 2015-11-09 2017-02-28 2 2 me@ewencp.org matthias@confluent.io
DataException.java
in connect/api/src/main/java/org/apache/kafka/connect/errors
 12 3 2015-11-09 2017-02-28 2 2 me@ewencp.org matthias@confluent.io
ConnectException.java
in connect/api/src/main/java/org/apache/kafka/connect/errors
 13 3 2015-11-09 2017-02-28 3 3 me@ewencp.org matthias@confluent.io
ConfigException.java
in clients/src/main/java/org/apache/kafka/common/config
 14 3 2014-02-07 2017-02-28 3 4 junrao@gmail.com matthias@confluent.io
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ForwardingManagerMetrics.java
in server/src/main/java/org/apache/kafka/server/metrics
 88 12 2025-05-06 2025-05-06 1 1 payang@apache.org payang@apache.org
PendingRemoteFetches.java
in core/src/main/java/kafka/server/share
 56 5 2025-05-05 2025-05-05 1 1 adixit@confluent.io adixit@confluent.io
AdminCommandFailedException.java
in tools/src/main/java/org/apache/kafka/tools
 9 2 2025-05-02 2025-05-02 1 1 jhenyunghsu@gmail.com jhenyunghsu@gmail.com
AdminOperationException.java
in tools/src/main/java/org/apache/kafka/tools
 9 2 2025-05-02 2025-05-02 1 1 jhenyunghsu@gmail.com jhenyunghsu@gmail.com
EndpointToPartitionsManager.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics
 62 3 2025-04-30 2025-04-30 1 1 bbejeck@apache.org bbejeck@apache.org
StreamsVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 46 6 2025-04-30 2025-04-30 1 1 matthias@confluent.io matthias@confluent.io
PreparedTxnState.java
in clients/src/main/java/org/apache/kafka/clients/producer
 65 8 2025-04-29 2025-04-29 1 1 98577846+rreddy-22@users.no... 98577846+rreddy-22@users.no...
TaskPluginsMetadata.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime
 95 14 2025-04-24 2025-04-24 1 1 snehashisp1995@gmail.com snehashisp1995@gmail.com
KRaftVersionUpgrade.java
in raft/src/main/java/org/apache/kafka/raft/internals
 30 6 2025-04-22 2025-04-22 1 1 jsancio@users.noreply.githu... jsancio@users.noreply.githu...
RaftClientKRaftVersionAccessor.java
in metadata/src/main/java/org/apache/kafka/controller
 15 3 2025-04-22 2025-04-22 1 1 jsancio@users.noreply.githu... jsancio@users.noreply.githu...
KRaftVersionAccessor.java
in metadata/src/main/java/org/apache/kafka/controller
 6 - 2025-04-22 2025-04-22 1 1 jsancio@users.noreply.githu... jsancio@users.noreply.githu...
RequestSendResult.java
in raft/src/main/java/org/apache/kafka/raft/internals
 6 1 2025-04-22 2025-04-22 1 1 jsancio@users.noreply.githu... jsancio@users.noreply.githu...
LogManager.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 52 2 2025-04-21 2025-04-21 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
RemoteLogManager.java
in storage/src/main/java/org/apache/kafka/server/log/remote/storage
 1657 110 2025-04-17 2025-04-25 3 3 mimaison@users.noreply.gith... payang@apache.org
RemoteLogReader.java
in storage/src/main/java/org/apache/kafka/server/log/remote/storage
 59 2 2025-04-17 2025-04-17 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
RemoteLogOffsetReader.java
in storage/src/main/java/org/apache/kafka/server/log/remote/storage
 53 2 2025-04-17 2025-04-17 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
ShareSessionLimitReachedException.java
in clients/src/main/java/org/apache/kafka/common/errors
 7 1 2025-04-16 2025-04-16 1 1 aschofield@confluent.io aschofield@confluent.io
ShareAcknowledgementMode.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 79 9 2025-04-15 2025-04-15 1 1 shr@confluent.io shr@confluent.io
DefaultApiVersionManager.java
in server/src/main/java/org/apache/kafka/server
 67 4 2025-04-15 2025-04-15 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
SimpleApiVersionManager.java
in server/src/main/java/org/apache/kafka/server
 49 4 2025-04-15 2025-04-15 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
ApiVersionManager.java
in server/src/main/java/org/apache/kafka/server
 18 2 2025-04-15 2025-04-15 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
TopicPartitionLog.java
in storage/src/main/java/org/apache/kafka/server/log/remote
 8 - 2025-04-15 2025-04-15 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
DelegationTokenManager.java
in server/src/main/java/org/apache/kafka/server
 91 8 2025-04-14 2025-04-14 1 1 payang@apache.org payang@apache.org
Cleaner.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 462 13 2025-04-11 2025-04-11 1 1 grimekillah@gmail.com grimekillah@gmail.com
LogCleaner.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 359 39 2025-04-11 2025-04-21 2 2 grimekillah@gmail.com gongxuanzhangmelt@gmail.com
ServerConfigs.java
in server-common/src/main/java/org/apache/kafka/server/config
 102 - 2025-04-11 2025-04-11 1 1 grimekillah@gmail.com grimekillah@gmail.com
CleanedTransactionMetadata.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 88 6 2025-04-11 2025-04-11 1 1 grimekillah@gmail.com grimekillah@gmail.com
CleanerStats.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 82 21 2025-04-11 2025-04-11 1 1 grimekillah@gmail.com grimekillah@gmail.com
ShareVersion.java
in server-common/src/main/java/org/apache/kafka/server/common
 49 6 2025-04-11 2025-05-01 2 1 aschofield@confluent.io aschofield@confluent.io
ShareGroupMessageFormatter.java
in tools/src/main/java/org/apache/kafka/tools/consumer
 33 4 2025-04-11 2025-04-11 1 1 aschofield@confluent.io aschofield@confluent.io
DefaultStreamsRebalanceListener.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 99 6 2025-04-10 2025-04-10 1 1 cadonna@apache.org cadonna@apache.org
StreamsRebalanceListener.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 8 - 2025-04-10 2025-04-10 1 1 cadonna@apache.org cadonna@apache.org
StreamsGroupCommand.java
in tools/src/main/java/org/apache/kafka/tools/streams
 331 25 2025-04-09 2025-04-28 3 1 107070585+aliehsaeedii@user... 107070585+aliehsaeedii@user...
DeleteShareGroupOffsetsHandler.java
in clients/src/main/java/org/apache/kafka/clients/admin/internals
 130 5 2025-04-09 2025-04-25 3 2 122860692+chirag-wadhwa5@us... 122860692+chirag-wadhwa5@us...
StreamsGroupCommandOptions.java
in tools/src/main/java/org/apache/kafka/tools/streams
 95 3 2025-04-09 2025-04-15 2 1 107070585+aliehsaeedii@user... 107070585+aliehsaeedii@user...
DeleteShareGroupOffsetsResult.java
in clients/src/main/java/org/apache/kafka/clients/admin
 62 3 2025-04-09 2025-04-25 2 1 122860692+chirag-wadhwa5@us... 122860692+chirag-wadhwa5@us...
DelayedFuturePurgatory.java
in server/src/main/java/org/apache/kafka/server/purgatory
 45 4 2025-04-09 2025-04-09 1 1 payang@apache.org payang@apache.org
DelayedFuture.java
in server/src/main/java/org/apache/kafka/server/purgatory
 40 4 2025-04-09 2025-04-09 1 1 payang@apache.org payang@apache.org
GroupProtocol.java
in streams/src/main/java/org/apache/kafka/streams
 13 1 2025-04-09 2025-04-09 1 1 cadonna@apache.org cadonna@apache.org
DeleteShareGroupOffsetsOptions.java
in clients/src/main/java/org/apache/kafka/clients/admin
 6 - 2025-04-09 2025-04-09 1 1 122860692+chirag-wadhwa5@us... 122860692+chirag-wadhwa5@us...
DelayedDeleteRecords.java
in server/src/main/java/org/apache/kafka/server/purgatory
 60 4 2025-04-08 2025-04-08 1 1 gongxuanzhangmelt@gmail.com gongxuanzhangmelt@gmail.com
DeleteRecordsPartitionStatus.java
in server/src/main/java/org/apache/kafka/server/purgatory
 31 6 2025-04-08 2025-04-08 1 1 gongxuanzhangmelt@gmail.com gongxuanzhangmelt@gmail.com
CloseOptions.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 36 7 2025-04-06 2025-05-03 2 2 kitingiao@gmail.com frankvicky@apache.org
BrokerReconfigurable.java
in server-common/src/main/java/org/apache/kafka/config
 8 - 2025-04-06 2025-04-06 1 1 kitingiao@gmail.com kitingiao@gmail.com
DelayedRemoteListOffsets.java
in storage/src/main/java/org/apache/kafka/server/purgatory
 146 5 2025-04-05 2025-04-05 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
ListOffsetsPartitionStatus.java
in storage/src/main/java/org/apache/kafka/server/purgatory
 84 14 2025-04-05 2025-04-05 1 1 mimaison@users.noreply.gith... mimaison@users.noreply.gith...
TerminateTransactionResult.java
in clients/src/main/java/org/apache/kafka/clients/admin
 11 1 2025-04-02 2025-04-02 1 1 98577846+rreddy-22@users.no... 98577846+rreddy-22@users.no...
TerminateTransactionOptions.java
in clients/src/main/java/org/apache/kafka/clients/admin
 9 1 2025-04-02 2025-04-02 1 1 98577846+rreddy-22@users.no... 98577846+rreddy-22@users.no...
LogCleanerManager.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 502 29 2025-03-27 2025-04-11 2 1 grimekillah@gmail.com grimekillah@gmail.com
LogToClean.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 96 14 2025-03-27 2025-03-27 1 1 grimekillah@gmail.com grimekillah@gmail.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 4131 156 2017-05-01 2025-05-07 252 103 cmccabe@confluent.io yunchipang@gmail.com
SharePartition.java
in core/src/main/java/kafka/server/share
 2060 116 2024-06-14 2025-05-07 55 11 apoorvmittal10@gmail.com adixit@confluent.io
DelayedShareFetch.java
in core/src/main/java/kafka/server/share
 650 31 2024-09-11 2025-05-07 27 5 adixit@confluent.io adixit@confluent.io
KafkaRaftClient.java
in raft/src/main/java/org/apache/kafka/raft
 3122 152 2020-09-22 2025-05-06 118 47 jason@confluent.io jsancio@users.noreply.githu...
GroupCoordinatorService.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 1746 58 2023-06-22 2025-05-06 66 22 djacot@confluent.io aschofield@confluent.io
ConsumerGroupCommand.java
in tools/src/main/java/org/apache/kafka/tools/consumer/group
 1164 44 2024-03-20 2025-05-06 16 10 nizhikov@apache.org aschofield@confluent.io
DynamicBrokerConfig.scala
in core/src/main/scala/kafka/server
 851 62 2018-01-23 2025-05-06 115 46 rajinisivaram@googlemail.com jsancio@users.noreply.githu...
ShareCoordinatorShard.java
in share-coordinator/src/main/java/org/apache/kafka/coordinator/share
 733 41 2024-08-19 2025-05-06 20 8 sushant.mahajan88@gmail.com aschofield@confluent.io
BrokerServer.scala
in core/src/main/scala/kafka/server
 642 9 2021-01-16 2025-05-06 196 66 jason@confluent.io jsancio@users.noreply.githu...
KafkaMetadataLog.scala
in core/src/main/scala/kafka/raft
 548 39 2020-09-22 2025-05-06 71 25 jason@confluent.io jsancio@users.noreply.githu...
ShareGroupCommand.java
in tools/src/main/java/org/apache/kafka/tools/consumer/group
 501 24 2024-08-14 2025-05-06 14 4 aschofield@confluent.io aschofield@confluent.io
Errors.java
in clients/src/main/java/org/apache/kafka/common/protocol
 492 12 2014-02-07 2025-05-06 129 61 junrao@gmail.com aschofield@confluent.io
DefaultStatePersister.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 486 19 2025-01-16 2025-05-06 6 4 apoorvmittal10@gmail.com aschofield@confluent.io
RecordsIterator.java
in raft/src/main/java/org/apache/kafka/raft/internals
 292 12 2021-05-01 2025-05-06 14 10 jsancio@users.noreply.githu... jsancio@users.noreply.githu...
KRaftControlRecordStateMachine.java
in raft/src/main/java/org/apache/kafka/raft/internals
 220 13 2024-05-04 2025-05-06 16 10 jsancio@users.noreply.githu... jsancio@users.noreply.githu...
ListShareGroupOffsetsHandler.java
in clients/src/main/java/org/apache/kafka/clients/admin/internals
 156 6 2025-02-05 2025-05-06 5 2 sjhajharia@confluent.io aschofield@confluent.io
ForwardingManager.scala
in core/src/main/scala/kafka/server
 146 7 2020-11-12 2025-05-06 22 10 boyang@confluent.io payang@apache.org
Snapshots.java
in raft/src/main/java/org/apache/kafka/snapshot
 134 12 2020-12-07 2025-05-06 16 11 jsancio@users.noreply.githu... jsancio@users.noreply.githu...
RecordsSnapshotReader.java
in raft/src/main/java/org/apache/kafka/snapshot
 114 9 2021-11-30 2025-05-06 11 7 317307889@qq.com jsancio@users.noreply.githu...
ReadShareGroupStateSummaryResponse.java
in clients/src/main/java/org/apache/kafka/common/requests
 107 9 2024-06-15 2025-05-06 5 4 aschofield@confluent.io aschofield@confluent.io
RecordsBatchReader.java
in raft/src/main/java/org/apache/kafka/raft/internals
 93 8 2020-11-02 2025-05-06 9 6 jason@confluent.io jsancio@users.noreply.githu...
ForwardingManagerMetrics.java
in server/src/main/java/org/apache/kafka/server/metrics
 88 12 2025-05-06 2025-05-06 1 1 payang@apache.org payang@apache.org
NoOpStatePersister.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 70 7 2025-02-18 2025-05-06 3 2 aschofield@confluent.io aschofield@confluent.io
DelayedShareFetchGroupKey.java
in server/src/main/java/org/apache/kafka/server/share/fetch
 39 6 2025-01-16 2025-05-06 2 1 apoorvmittal10@gmail.com apoorvmittal10@gmail.com
ListShareGroupOffsetsResult.java
in clients/src/main/java/org/apache/kafka/clients/admin
 38 - 2025-01-20 2025-05-06 4 4 payang@apache.org aschofield@confluent.io
ReadShareGroupStateSummaryResult.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 35 4 2025-01-16 2025-05-06 3 3 apoorvmittal10@gmail.com aschofield@confluent.io
PartitionFactory.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 31 7 2025-01-16 2025-05-06 3 3 apoorvmittal10@gmail.com aschofield@confluent.io
ListStreamsGroupOffsetsOptions.java
in clients/src/main/java/org/apache/kafka/clients/admin
 13 2 2025-03-05 2025-05-06 3 1 107070585+aliehsaeedii@user... 107070585+aliehsaeedii@user...
PartitionStateSummaryData.java
in server-common/src/main/java/org/apache/kafka/server/share/persister
 8 - 2025-01-20 2025-05-06 2 2 sjhajharia@confluent.io aschofield@confluent.io
PendingRemoteFetches.java
in core/src/main/java/kafka/server/share
 56 5 2025-05-05 2025-05-05 1 1 adixit@confluent.io adixit@confluent.io
Metadata.java
in clients/src/main/java/org/apache/kafka/clients
 525 49 2015-02-03 2025-05-04 63 36 jay.kreps@gmail.com yunchipang@gmail.com
AssignmentsManager.java
in server/src/main/java/org/apache/kafka/server
 367 20 2023-11-20 2025-05-04 17 13 ismael@juma.me.uk yunchipang@gmail.com
KafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 290 57 2014-05-20 2025-05-04 298 130 neha.narkhede@gmail.com s7133700@gmail.com
ShareSessionHandler.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 186 11 2024-07-16 2025-05-04 9 5 aschofield@confluent.io shr@confluent.io
ClusterTool.java
in tools/src/main/java/org/apache/kafka/tools
 165 6 2023-01-22 2025-05-04 5 5 mimaison@users.noreply.gith... yunchipang@gmail.com
DescribeUserScramCredentialsResult.java
in clients/src/main/java/org/apache/kafka/clients/admin
 81 2 2020-09-04 2025-05-04 4 4 rdagostino@confluent.io yunchipang@gmail.com
UnifiedLog.java
in storage/src/main/java/org/apache/kafka/storage/internals/log
 1748 155 2024-09-16 2025-05-03 9 7 mimaison@users.noreply.gith... jhenyunghsu@gmail.com
AsyncKafkaConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1650 111 2023-11-15 2025-05-03 88 26 kirk@kirktrue.pro 422766572@qq.com
ShareCoordinatorService.java
in share-coordinator/src/main/java/org/apache/kafka/coordinator/share
 854 34 2024-09-10 2025-05-03 17 7 sushant.mahajan88@gmail.com smahajan@confluent.io
MockConsumer.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 557 77 2014-05-20 2025-05-03 87 47 neha.narkhede@gmail.com matthias@confluent.io
CloseOptions.java
in clients/src/main/java/org/apache/kafka/clients/consumer
 36 7 2025-04-06 2025-05-03 2 2 kitingiao@gmail.com frankvicky@apache.org
GroupMetadataManager.java
in group-coordinator/src/main/java/org/apache/kafka/coordinator/group
 5425 228 2023-05-31 2025-05-02 112 26 djacot@confluent.io smahajan@confluent.io
ReassignPartitionsCommand.java
in tools/src/main/java/org/apache/kafka/tools/reassign
 1054 37 2023-11-01 2025-05-02 18 14 nizhikov@apache.org jhenyunghsu@gmail.com
TopicCommand.java
in tools/src/main/java/org/apache/kafka/tools
 834 71 2023-10-17 2025-05-02 17 17 o.g.h.ibrahim@gmail.com jhenyunghsu@gmail.com
LeaderElectionCommand.java
in tools/src/main/java/org/apache/kafka/tools
 323 18 2023-10-03 2025-05-02 7 7 o.g.h.ibrahim@gmail.com jhenyunghsu@gmail.com
DeleteRecordsCommand.java
in tools/src/main/java/org/apache/kafka/tools
 137 6 2023-07-21 2025-05-02 4 4 nizhikov@apache.org jhenyunghsu@gmail.com
BatchingStateRestoreCallback.java
in streams/src/main/java/org/apache/kafka/streams/processor
 10 1 2017-07-28 2025-05-02 4 4 bill@confluent.io matthias@confluent.io
AdminCommandFailedException.java
in tools/src/main/java/org/apache/kafka/tools
 9 2 2025-05-02 2025-05-02 1 1 jhenyunghsu@gmail.com jhenyunghsu@gmail.com
AdminOperationException.java
in tools/src/main/java/org/apache/kafka/tools
 9 2 2025-05-02 2025-05-02 1 1 jhenyunghsu@gmail.com jhenyunghsu@gmail.com
KafkaApis.scala
in core/src/main/scala/kafka/server
 3343 94 2012-01-13 2025-05-01 615 148 nehanarkhede@apache.org cwadhwa@confluent.io