apache / kafka-merge-queue-sandbox
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,485 files with 389,399 lines of code in files.
    • 0 files that are 366+ days old (0 lines of code)
    • 1 files that are 181-365 days old (43 lines of code)
    • 3,484 files that are 91-180 days old (389,356 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
0% | <1% | 99% | 0% | 0%
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,485 files with 389,399 lines of code in files.
    • 0 files have been last changed 366+ days ago (0 lines of code)
    • 1 files have been last changed 181-365 days ago (43 lines of code)
    • 3,484 files have been last changed 91-180 days ago (389,356 lines of code)
    • 0 files have been last changed 31-90 days ago (0 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
0% | <1% | 99% | 0% | 0%
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, html, sh, yaml, bat, py, properties, xml, md, gitignore, txt, gradle, svg, js, xsl, awk, rdf
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
py0% | 3% | 96% | 0% | 0%
java0% | 0% | 100% | 0% | 0%
scala0% | 0% | 100% | 0% | 0%
xml0% | 0% | 100% | 0% | 0%
yaml0% | 0% | 100% | 0% | 0%
xsl0% | 0% | 100% | 0% | 0%
rdf0% | 0% | 100% | 0% | 0%
html0% | 0% | 100% | 0% | 0%
awk0% | 0% | 100% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
py0% | 3% | 96% | 0% | 0%
java0% | 0% | 100% | 0% | 0%
scala0% | 0% | 100% | 0% | 0%
xml0% | 0% | 100% | 0% | 0%
yaml0% | 0% | 100% | 0% | 0%
xsl0% | 0% | 100% | 0% | 0%
rdf0% | 0% | 100% | 0% | 0%
html0% | 0% | 100% | 0% | 0%
awk0% | 0% | 100% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
ROOT0% | 55% | 44% | 0% | 0%
clients0% | 0% | 100% | 0% | 0%
streams0% | 0% | 100% | 0% | 0%
connect0% | 0% | 100% | 0% | 0%
core0% | 0% | 100% | 0% | 0%
metadata0% | 0% | 100% | 0% | 0%
tools0% | 0% | 100% | 0% | 0%
group-coordinator0% | 0% | 100% | 0% | 0%
raft0% | 0% | 100% | 0% | 0%
storage0% | 0% | 100% | 0% | 0%
server-common0% | 0% | 100% | 0% | 0%
trogdor0% | 0% | 100% | 0% | 0%
generator0% | 0% | 100% | 0% | 0%
jmh-benchmarks0% | 0% | 100% | 0% | 0%
server0% | 0% | 100% | 0% | 0%
coordinator-common0% | 0% | 100% | 0% | 0%
share-coordinator0% | 0% | 100% | 0% | 0%
shell0% | 0% | 100% | 0% | 0%
release0% | 0% | 100% | 0% | 0%
gradle0% | 0% | 100% | 0% | 0%
committer-tools0% | 0% | 100% | 0% | 0%
transaction-coordinator0% | 0% | 100% | 0% | 0%
docker0% | 0% | 100% | 0% | 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
ROOT0% | 55% | 44% | 0% | 0%
clients0% | 0% | 100% | 0% | 0%
streams0% | 0% | 100% | 0% | 0%
connect0% | 0% | 100% | 0% | 0%
core0% | 0% | 100% | 0% | 0%
metadata0% | 0% | 100% | 0% | 0%
tools0% | 0% | 100% | 0% | 0%
group-coordinator0% | 0% | 100% | 0% | 0%
raft0% | 0% | 100% | 0% | 0%
storage0% | 0% | 100% | 0% | 0%
server-common0% | 0% | 100% | 0% | 0%
trogdor0% | 0% | 100% | 0% | 0%
generator0% | 0% | 100% | 0% | 0%
jmh-benchmarks0% | 0% | 100% | 0% | 0%
server0% | 0% | 100% | 0% | 0%
coordinator-common0% | 0% | 100% | 0% | 0%
share-coordinator0% | 0% | 100% | 0% | 0%
shell0% | 0% | 100% | 0% | 0%
release0% | 0% | 100% | 0% | 0%
gradle0% | 0% | 100% | 0% | 0%
committer-tools0% | 0% | 100% | 0% | 0%
transaction-coordinator0% | 0% | 100% | 0% | 0%
docker0% | 0% | 100% | 0% | 0%
config0% | 0% | 100% | 0% | 0%
test-common0% | 0% | 100% | 0% | 0%
Oldest Files (Top 50)
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
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
Files Not Recently Changed (Top 50)
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
Most Recently Created Files (Top 50)
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
Most Recently Changed Files (Top 50)
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