Apache KafkaFile Change Frequency
File change frequency measurements show the distribution of the number of file updates (days with at least one commit).
File Change Frequency Overall
File Change Frequency Overall
The number of recorded file updates
- There are 1,964 files with 212,448 lines of code.
- 27 files changed more than 100 times (28,263 lines of code)
- 50 files 51 to 100 times (31,390 lines of code)
- 159 files changed 21 to 50 times (39,972 lines of code)
- 561 files changed 6 to 20 times (59,501 lines of code)
- 1,167 files changed 5 or fewer times (53,322 lines of code)
Legend:
101+
51-100
21-50
6-20
1-5 updates
File Change Frequency per File Extension
java, scala
File Change Frequency per Extension
The number of recorded file updates
Legend:
101+
51-100
21-50
6-20
1-5 updates
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
Legend:
101+
51-100
21-50
6-20
1-5 updates
Most Frequently Changed Files (Top 50)
| File | # lines | # units | last modified (days ago) | created (days ago) | # changes |
|---|---|---|---|---|---|
| KafkaApis.scala in core/src/main/scala/kafka/server |
2720 | 86 | 2 | 3165 | 388 |
| ReplicaManager.scala in core/src/main/scala/kafka/server |
1383 | 55 | 2 | 3095 | 250 |
| KafkaServer.scala in core/src/main/scala/kafka/server |
587 | 14 | 45 | 3330 | 234 |
| KafkaConfig.scala in core/src/main/scala/kafka/server |
1508 | 25 | 26 | 3330 | 234 |
| Log.scala in core/src/main/scala/kafka/log |
1638 | 88 | 2 | 3330 | 234 |
| StreamThread.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
725 | 44 | 2 | 1814 | 232 |
| KafkaConsumer.java in clients/src/main/java/org/apache/kafka/clients/consumer |
879 | 63 | 2 | 2307 | 228 |
| KafkaController.scala in core/src/main/scala/kafka/controller |
1519 | 114 | 8 | 2916 | 196 |
| Partition.scala in core/src/main/scala/kafka/cluster |
827 | 51 | 2 | 3330 | 174 |
| KafkaProducer.java in clients/src/main/java/org/apache/kafka/clients/producer |
692 | 42 | 44 | 2410 | 170 |
| StreamTask.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
774 | 53 | 19 | 1814 | 167 |
| Fetcher.java in clients/src/main/java/org/apache/kafka/clients/consumer/internals |
1432 | 60 | 22 | 2013 | 162 |
| ReplicaFetcherThread.scala in core/src/main/scala/kafka/server |
249 | 17 | 109 | 3025 | 132 |
| ControllerChannelManager.scala in core/src/main/scala/kafka/controller |
569 | 22 | 74 | 2916 | 132 |
| KafkaStreams.java in streams/src/main/java/org/apache/kafka/streams |
713 | 46 | 30 | 1695 | 132 |
| SocketServer.scala in core/src/main/scala/kafka/network |
1055 | 82 | 25 | 3330 | 132 |
| ConsumerCoordinator.java in clients/src/main/java/org/apache/kafka/clients/consumer/internals |
1046 | 46 | 2 | 1788 | 128 |
| KafkaAdminClient.java in clients/src/main/java/org/apache/kafka/clients/admin |
3377 | 119 | 8 | 1230 | 128 |
| StreamsConfig.java in streams/src/main/java/org/apache/kafka/streams |
840 | 34 | 19 | 1695 | 127 |
| LogManager.scala in core/src/main/scala/kafka/log |
840 | 42 | 44 | 3330 | 127 |
| Sender.java in clients/src/main/java/org/apache/kafka/clients/producer/internals |
657 | 36 | 25 | 2410 | 121 |
| NetworkClient.java in clients/src/main/java/org/apache/kafka/clients |
903 | 68 | 25 | 2286 | 110 |
| AbstractCoordinator.java in clients/src/main/java/org/apache/kafka/clients/consumer/internals |
1047 | 75 | 2 | 1788 | 109 |
| KStreamImpl.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
1159 | 84 | 3 | 1814 | 109 |
| AbstractFetcherThread.scala in core/src/main/scala/kafka/server |
550 | 33 | 57 | 3003 | 108 |
| KStream.java in streams/src/main/java/org/apache/kafka/streams/kstream |
178 | - | 85 | 1814 | 103 |
| RequestChannel.scala in core/src/main/scala/kafka/network |
396 | 19 | 25 | 3165 | 102 |
| ProducerConfig.java in clients/src/main/java/org/apache/kafka/clients/producer |
418 | 15 | 19 | 2410 | 100 |
| TopicCommand.scala in core/src/main/scala/kafka/admin |
649 | 39 | 22 | 2745 | 98 |
| LogCleaner.scala in core/src/main/scala/kafka/log |
717 | 50 | 60 | 2784 | 98 |
| RocksDBStore.java in streams/src/main/java/org/apache/kafka/streams/state/internals |
487 | 36 | 15 | 1697 | 97 |
| KTableImpl.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
947 | 60 | 3 | 1744 | 97 |
| Errors.java in clients/src/main/java/org/apache/kafka/common/protocol |
400 | 11 | 8 | 2410 | 93 |
| AdminUtils.scala in core/src/main/scala/kafka/admin |
120 | 6 | 250 | 3165 | 92 |
| ProcessorStateManager.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
478 | 40 | 32 | 1814 | 92 |
| Utils.java in clients/src/main/java/org/apache/kafka/common/utils |
723 | 72 | 78 | 2410 | 92 |
| TaskManager.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
917 | 55 | 31 | 1128 | 90 |
| LogSegment.scala in core/src/main/scala/kafka/log |
400 | 31 | 4 | 2896 | 89 |
| Selector.java in clients/src/main/java/org/apache/kafka/common/network |
1023 | 80 | 93 | 2410 | 88 |
| MirrorMaker.scala in core/src/main/scala/kafka/tools |
435 | 25 | 124 | 3026 | 87 |
| RecordAccumulator.java in clients/src/main/java/org/apache/kafka/clients/producer/internals |
516 | 36 | 70 | 2410 | 87 |
| ApiKeys.java in clients/src/main/java/org/apache/kafka/common/protocol |
346 | 18 | 8 | 2410 | 82 |
| ConsumerConfig.java in clients/src/main/java/org/apache/kafka/clients/consumer |
450 | 13 | 19 | 2307 | 82 |
| ReplicaStateMachine.scala in core/src/main/scala/kafka/controller |
334 | 12 | 99 | 2916 | 78 |
| StandbyTask.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
210 | 17 | 32 | 1762 | 75 |
| ConsoleConsumer.scala in core/src/main/scala/kafka/tools |
464 | 23 | 71 | 2292 | 75 |
| ConsumerGroupCommand.scala in core/src/main/scala/kafka/admin |
1008 | 42 | 78 | 2041 | 75 |
| PartitionStateMachine.scala in core/src/main/scala/kafka/controller |
405 | 22 | 99 | 2916 | 74 |
| DumpLogSegments.scala in core/src/main/scala/kafka/tools |
351 | 15 | 164 | 3308 | 72 |
| TopologyTestDriver.java in streams/test-utils/src/main/java/org/apache/kafka/streams |
762 | 51 | 25 | 957 | 71 |