microsoft / kafka
File Age

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

Summary
  • Number of files: 1474
  • Daily file updates (only one update per file and date counted): 4217
  • First update: 2011-08-03
  • Latest update: 2018-02-02
  • Days between first and latest update: 2376 (339 weeks, estimated 1695 working days)
  • Active days (at least one file change): 1424
  • Data:
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 1,474 files with 143,848 lines of code in files.
    • 1,474 files that are 366+ days old (143,848 lines of code)
    • 0 files that are 181-365 days old (0 lines of code)
    • 0 files that are 91-180 days old (0 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)
100% | 0% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30
Latest Change Distribution Overall
Days since last update
  • There are 1,474 files with 143,848 lines of code in files.
    • 1,474 files have been last changed 366+ days ago (143,848 lines of code)
    • 0 files have been last changed 181-365 days ago (0 lines of code)
    • 0 files have been last changed 91-180 days ago (0 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)
100% | 0% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30
File Change History per File Extension
java, scala, py, html, sh, properties, bat, xml, gitignore, gradle, md, cfg, txt, in, js, xsl, rdf, json, yml, pub
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
scala100% | 0% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
xsl100% | 0% | 0% | 0% | 0%
rdf100% | 0% | 0% | 0% | 0%
html100% | 0% | 0% | 0% | 0%
Latest Change Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java100% | 0% | 0% | 0% | 0%
scala100% | 0% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
xsl100% | 0% | 0% | 0% | 0%
rdf100% | 0% | 0% | 0% | 0%
html100% | 0% | 0% | 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
clients/src100% | 0% | 0% | 0% | 0%
core/src100% | 0% | 0% | 0% | 0%
streams/src100% | 0% | 0% | 0% | 0%
connect/runtime100% | 0% | 0% | 0% | 0%
tools/src100% | 0% | 0% | 0% | 0%
connect/api100% | 0% | 0% | 0% | 0%
connect/transforms100% | 0% | 0% | 0% | 0%
connect/json100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
connect/file100% | 0% | 0% | 0% | 0%
streams/test-utils100% | 0% | 0% | 0% | 0%
log4j-appender/src100% | 0% | 0% | 0% | 0%
jmh-benchmarks/src100% | 0% | 0% | 0% | 0%
gradle/resources100% | 0% | 0% | 0% | 0%
streams/quickstart100% | 0% | 0% | 0% | 0%
primary (latest change distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
clients/src100% | 0% | 0% | 0% | 0%
core/src100% | 0% | 0% | 0% | 0%
streams/src100% | 0% | 0% | 0% | 0%
connect/runtime100% | 0% | 0% | 0% | 0%
tools/src100% | 0% | 0% | 0% | 0%
connect/api100% | 0% | 0% | 0% | 0%
connect/transforms100% | 0% | 0% | 0% | 0%
connect/json100% | 0% | 0% | 0% | 0%
ROOT100% | 0% | 0% | 0% | 0%
connect/file100% | 0% | 0% | 0% | 0%
streams/test-utils100% | 0% | 0% | 0% | 0%
log4j-appender/src100% | 0% | 0% | 0% | 0%
jmh-benchmarks/src100% | 0% | 0% | 0% | 0%
gradle/resources100% | 0% | 0% | 0% | 0%
streams/quickstart100% | 0% | 0% | 0% | 0%
Oldest Files (Top 20)
File# lines# unitslast modified
(days ago)		created
(days ago)		# changes
ZkUtils.scala
in core/src/main/scala/kafka/utils
 915 89 1459 3830 150
ZookeeperConsumerConnector.scala
in core/src/main/scala/kafka/consumer
 765 39 1459 3830 127
ReplayLogProducer.scala
in core/src/main/scala/kafka/tools
 128 3 1459 3830 31
ProducerPool.scala
in core/src/main/scala/kafka/producer
 59 4 1459 3830 24
Log.scala
in core/src/main/scala/kafka/log
 1086 63 1459 3827 173
KafkaConfig.scala
in core/src/main/scala/kafka/server
 1063 9 1459 3827 185
LogManager.scala
in core/src/main/scala/kafka/log
 682 28 1459 3827 105
SocketServer.scala
in core/src/main/scala/kafka/network
 566 38 1459 3827 101
KafkaServer.scala
in core/src/main/scala/kafka/server
 480 10 1459 3827 199
Partition.scala
in core/src/main/scala/kafka/cluster
 447 27 1459 3827 122
ConsumerPerformance.scala
in core/src/main/scala/kafka/tools
 349 8 1459 3827 26
DefaultEventHandler.scala
in core/src/main/scala/kafka/producer/async
 292 9 1459 3827 74
ProducerPerformance.scala
in core/src/main/scala/kafka/tools
 257 3 1459 3827 26
SimpleConsumerShell.scala
in core/src/main/scala/kafka/tools
 219 1 1459 3827 44
FetchRequest.scala
in core/src/main/scala/kafka/api
 213 16 1459 3827 62
Message.scala
in core/src/main/scala/kafka/message
 172 9 1459 3827 27
SimpleConsumerPerformance.scala
in core/src/main/scala/kafka/tools
 123 1 1459 3827 12
SimpleConsumer.scala
in core/src/main/scala/kafka/consumer
 119 12 1459 3827 59
SyncProducer.scala
in core/src/main/scala/kafka/producer
 116 8 1459 3827 52
ConsumerConfig.scala
in core/src/main/scala/kafka/consumer
 113 7 1459 3827 40
Files Not Recently Changed (Top 20)
File# lines# unitslast modified
(days ago)		created
(days ago)		# changes
UnknownException.scala
in core/src/main/scala/kafka/common
 2 - 3827 3827 1
UnknownMagicByteException.scala
in core/src/main/scala/kafka/common
 4 - 3827 3827 1
UnknownCodecException.scala
in core/src/main/scala/kafka/common
 4 - 3827 3827 1
UnavailableProducerException.scala
in core/src/main/scala/kafka/common
 4 - 3827 3827 1
OffsetOutOfRangeException.scala
in core/src/main/scala/kafka/common
 4 - 3827 3827 1
InvalidConfigException.scala
in core/src/main/scala/kafka/common
 4 - 3827 3827 1
NoBrokersForPartitionException.scala
in core/src/main/scala/kafka/common
 4 - 3770 3770 1
InvalidMessageSizeException.scala
in core/src/main/scala/kafka/common
 4 - 3770 3770 1
FailedToSendMessageException.scala
in core/src/main/scala/kafka/common
 3 - 3353 3645 2
RequestTimedOutException.scala
in core/src/main/scala/kafka/common
 4 - 3353 3503 2
QueueFullException.scala
in core/src/main/scala/kafka/common
 4 - 3353 3570 2
NotLeaderForPartitionException.scala
in core/src/main/scala/kafka/common
 4 - 3353 3535 3
NoEpochForPartitionException.scala
in core/src/main/scala/kafka/common
 4 - 3353 3570 2
MessageSizeTooLargeException.scala
in core/src/main/scala/kafka/common
 4 - 3353 3402 2
BrokerNotAvailableException.scala
in core/src/main/scala/kafka/common
 4 - 3353 3430 2
StateChangeFailedException.scala
in core/src/main/scala/kafka/common
 5 - 3353 3422 3
ReplicaNotAvailableException.scala
in core/src/main/scala/kafka/common
 5 - 3353 3478 3
KafkaException.scala
in core/src/main/scala/kafka/common
 5 - 3353 3478 2
ControllerMovedException.scala
in core/src/main/scala/kafka/common
 5 - 3353 3361 2
AdminCommandFailedException.scala
in core/src/main/scala/kafka/common
 5 - 3353 3400 2
Most Recently Created Files (Top 20)
File# lines# unitslast modified
(days ago)		created
(days ago)		# changes
Values.java
in connect/api/src/main/java/org/apache/kafka/connect/data
 824 41 1459 1461 2
ConnectHeaders.java
in connect/api/src/main/java/org/apache/kafka/connect/header
 419 45 1459 1461 2
DeleteGroupsResponse.java
in clients/src/main/java/org/apache/kafka/common/requests
 81 10 1459 1461 2
DeleteGroupsRequest.java
in clients/src/main/java/org/apache/kafka/common/requests
 80 9 1459 1461 2
ConnectHeader.java
in connect/api/src/main/java/org/apache/kafka/connect/header
 64 9 1459 1461 2
SimpleHeaderConverter.java
in connect/api/src/main/java/org/apache/kafka/connect/storage
 54 4 1459 1461 2
Headers.java
in connect/api/src/main/java/org/apache/kafka/connect/header
 44 - 1459 1461 2
JsonConverterConfig.java
in connect/json/src/main/java/org/apache/kafka/connect/json
 39 5 1459 1461 2
ConverterType.java
in connect/api/src/main/java/org/apache/kafka/connect/storage
 32 3 1459 1461 2
StringConverterConfig.java
in connect/api/src/main/java/org/apache/kafka/connect/storage
 27 4 1459 1461 2
ConverterConfig.java
in connect/api/src/main/java/org/apache/kafka/connect/storage
 22 3 1459 1461 2
HeaderConverter.java
in connect/api/src/main/java/org/apache/kafka/connect/storage
 12 - 1459 1461 2
GroupIdNotFoundException.java
in clients/src/main/java/org/apache/kafka/common/errors
 11 2 1459 1461 2
GroupNotEmptyException.java
in clients/src/main/java/org/apache/kafka/common/errors
 11 2 1459 1461 2
Header.java
in connect/api/src/main/java/org/apache/kafka/connect/header
 9 - 1459 1461 2
TopologyTestDriver.java
in streams/test-utils/src/main/java/org/apache/kafka/streams
 345 18 1459 1462 2
RestClient.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest
 106 6 1459 1462 2
KTableKTableInnerJoin.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 91 7 1459 1462 2
SSLUtils.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/util
 86 8 1459 1462 2
DynamicBrokerConfig.scala
in core/src/main/scala/kafka/server
 444 43 1459 1469 6
Most Recently Changed Files (Top 20)
File# lines# unitslast modified
(days ago)		created
(days ago)		# changes
KafkaApis.scala
in core/src/main/scala/kafka/server
 1829 72 1459 3671 259
KafkaAdminClient.java
in clients/src/main/java/org/apache/kafka/clients/admin
 1534 56 1459 1736 34
InternalTopologyBuilder.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 1507 126 1459 1652 18
KafkaController.scala
in core/src/main/scala/kafka/controller
 1104 76 1459 3422 151
ReplicaManager.scala
in core/src/main/scala/kafka/server
 1101 44 1459 3601 180
Log.scala
in core/src/main/scala/kafka/log
 1086 63 1459 3827 173
KafkaConfig.scala
in core/src/main/scala/kafka/server
 1063 9 1459 3827 185
Fetcher.java
in clients/src/main/java/org/apache/kafka/clients/consumer/internals
 1034 45 1459 2519 104
DistributedHerder.java
in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed
 987 61 1459 2275 33
TransactionManager.java
in clients/src/main/java/org/apache/kafka/clients/producer/internals
 986 106 1459 1740 29
GroupMetadataManager.scala
in core/src/main/scala/kafka/coordinator/group
 926 46 1459 1741 23
ZkUtils.scala
in core/src/main/scala/kafka/utils
 915 89 1459 3830 150
KafkaZkClient.scala
in core/src/main/scala/kafka/zk
 901 99 1459 1558 19
ConsumerGroupCommand.scala
in core/src/main/scala/kafka/admin
 892 42 1459 2547 50
StreamThread.java
in streams/src/main/java/org/apache/kafka/streams/processor/internals
 836 44 1459 2319 136
Values.java
in connect/api/src/main/java/org/apache/kafka/connect/data
 824 41 1459 1461 2
ConfigDef.java
in clients/src/main/java/org/apache/kafka/common/config
 801 72 1459 2915 45
KStreamImpl.java
in streams/src/main/java/org/apache/kafka/streams/kstream/internals
 769 77 1459 2319 68
ZookeeperConsumerConnector.scala
in core/src/main/scala/kafka/consumer
 765 39 1459 3830 127
Selector.java
in clients/src/main/java/org/apache/kafka/common/network
 739 61 1459 2915 63