Apache KafkaFile 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: 1964
- Daily file updates (only one update per file and date counted): 3771
- First update: 2011-08-01
- Latest update: 2020-09-10
- Days between first and latest update: 3329 (475 weeks, estimated 2375 working days)
- Active days (at least one file change): 2075
- Data:
File Change History Overall
File Age Distribution Overall
Days since first update
- There are 1,964 files with 212,448 lines of code in files.
- 1,702 files older than 1 year (193,544 lines of code)
- 151 files are 180 days to 1 year old (12,324 lines of code)
- 47 files are 90 to 180 days old (3,179 lines of code)
- 35 files are 30 to 90 days old (1,580 lines of code)
- 29 files are less than 30 days old (1,821 lines of code)
Legend:
> 1y
6-12m
91-180d
31-90d
1-30d
Latest Change Distribution Overall
Days since last update
- There are 1,964 files with 212,448 lines of code in files.
- 897 files have been last changed more than 1 year ago (34,204 lines of code)
- 286 files have been last changed 180 days to 1 year ago (24,122 lines of code)
- 344 files have been last changed 90 to 180 days ago (44,988 lines of code)
- 227 files have been last changed 30 to 90 days ago (44,986 lines of code)
- 210 files have been last changed less than 30 days ago (64,148 lines of code)
Legend:
> 1y
6-12m
91-180d
31-90d
1-30d
File Change History per File Extension
java, scala
File Age Distribution per Extension
Days since first update
Legend:
> 1y
6-12m
91-180d
31-90d
1-30d
Latest Change Distribution per Extension
Days since last update
Legend:
> 1y
6-12m
91-180d
31-90d
1-30d
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
Legend:
> 1y
6-12m
91-180d
31-90d
1-30d
primary (latest change distribution)
Days since last update
Legend:
> 1y
6-12m
91-180d
31-90d
1-30d
Oldest Files (Top 50)
| File | # lines | # units | last modified (days ago) | created (days ago) | # changes |
|---|---|---|---|---|---|
| Log.scala in core/src/main/scala/kafka/log |
1638 | 88 | 2 | 3330 | 234 |
| KafkaConfig.scala in core/src/main/scala/kafka/server |
1508 | 25 | 26 | 3330 | 234 |
| SocketServer.scala in core/src/main/scala/kafka/network |
1055 | 82 | 25 | 3330 | 132 |
| LogManager.scala in core/src/main/scala/kafka/log |
840 | 42 | 44 | 3330 | 127 |
| Partition.scala in core/src/main/scala/kafka/cluster |
827 | 51 | 2 | 3330 | 174 |
| KafkaServer.scala in core/src/main/scala/kafka/server |
587 | 14 | 45 | 3330 | 234 |
| ConsumerPerformance.scala in core/src/main/scala/kafka/tools |
251 | 6 | 49 | 3330 | 40 |
| GetOffsetShell.scala in core/src/main/scala/kafka/tools |
115 | 2 | 164 | 3330 | 18 |
| Producer.java in examples/src/main/java/kafka/examples |
94 | 5 | 204 | 3330 | 16 |
| KafkaScheduler.scala in core/src/main/scala/kafka/utils |
80 | 8 | 250 | 3330 | 28 |
| CompressionCodec.scala in core/src/main/scala/kafka/message |
74 | 4 | 225 | 3330 | 13 |
| Consumer.java in examples/src/main/java/kafka/examples |
70 | 5 | 205 | 3330 | 17 |
| Throttler.scala in core/src/main/scala/kafka/utils |
65 | 2 | 393 | 3330 | 11 |
| Broker.scala in core/src/main/scala/kafka/cluster |
57 | 7 | 93 | 3330 | 36 |
| Kafka.scala in core/src/main/scala/kafka |
55 | 2 | 78 | 3330 | 32 |
| KafkaServerStartable.scala in core/src/main/scala/kafka/server |
38 | 5 | 382 | 3330 | 29 |
| Pool.scala in core/src/main/scala/kafka/utils |
38 | 4 | 50 | 3330 | 20 |
| Decoder.scala in core/src/main/scala/kafka/serializer |
29 | 5 | 1179 | 3330 | 8 |
| KafkaConsumerProducerDemo.java in examples/src/main/java/kafka/examples |
20 | 1 | 205 | 3330 | 11 |
| DelayedItem.scala in core/src/main/scala/kafka/utils |
15 | 2 | 708 | 3330 | 9 |
| KafkaProperties.java in examples/src/main/java/kafka/examples |
7 | 1 | 205 | 3330 | 7 |
| Annotations.scala in core/src/main/scala/kafka/utils |
5 | - | 1262 | 3330 | 5 |
| UnknownCodecException.scala in core/src/main/scala/kafka/common |
4 | - | 3321 | 3330 | 2 |
| DumpLogSegments.scala in core/src/main/scala/kafka/tools |
351 | 15 | 164 | 3308 | 72 |
| Mx4jLoader.scala in core/src/main/scala/kafka/utils |
37 | 1 | 670 | 3264 | 11 |
| JmxTool.scala in core/src/main/scala/kafka/tools |
221 | 3 | 164 | 3246 | 26 |
| Logging.scala in core/src/main/scala/kafka/utils |
41 | - | 935 | 3216 | 13 |
| KafkaApis.scala in core/src/main/scala/kafka/server |
2720 | 86 | 2 | 3165 | 388 |
| RequestChannel.scala in core/src/main/scala/kafka/network |
396 | 19 | 25 | 3165 | 102 |
| KafkaRequestHandler.scala in core/src/main/scala/kafka/server |
273 | 19 | 39 | 3165 | 50 |
| AdminUtils.scala in core/src/main/scala/kafka/admin |
120 | 6 | 250 | 3165 | 92 |
| Replica.scala in core/src/main/scala/kafka/cluster |
54 | 3 | 108 | 3097 | 43 |
| ReplicaManager.scala in core/src/main/scala/kafka/server |
1383 | 55 | 2 | 3095 | 250 |
| NoEpochForPartitionException.scala in core/src/main/scala/kafka/common |
4 | - | 3064 | 3064 | 1 |
| MirrorMaker.scala in core/src/main/scala/kafka/tools |
435 | 25 | 124 | 3026 | 87 |
| ReplicaFetcherThread.scala in core/src/main/scala/kafka/server |
249 | 17 | 109 | 3025 | 132 |
| AbstractFetcherThread.scala in core/src/main/scala/kafka/server |
550 | 33 | 57 | 3003 | 108 |
| AbstractFetcherManager.scala in core/src/main/scala/kafka/server |
159 | 13 | 52 | 3003 | 38 |
| ReplicaFetcherManager.scala in core/src/main/scala/kafka/server |
26 | 2 | 393 | 3003 | 20 |
| KafkaException.scala in core/src/main/scala/kafka/common |
5 | - | 448 | 2972 | 3 |
| KafkaMetricsGroup.scala in core/src/main/scala/kafka/metrics |
58 | 4 | 212 | 2949 | 24 |
| KafkaCSVMetricsReporter.scala in core/src/main/scala/kafka/metrics |
51 | 3 | 212 | 2949 | 12 |
| KafkaMetricsReporter.scala in core/src/main/scala/kafka/metrics |
38 | 3 | 393 | 2949 | 9 |
| KafkaMetricsConfig.scala in core/src/main/scala/kafka/metrics |
10 | - | 225 | 2949 | 6 |
| KafkaTimer.scala in core/src/main/scala/kafka/metrics |
9 | 1 | 1207 | 2949 | 3 |
| ShutdownableThread.scala in core/src/main/scala/kafka/utils |
65 | 5 | 337 | 2944 | 12 |
| VerifiableProperties.scala in core/src/main/scala/kafka/utils |
118 | 13 | 164 | 2940 | 17 |
| Log4jController.scala in core/src/main/scala/kafka/utils |
68 | 5 | 3 | 2940 | 7 |
| KafkaController.scala in core/src/main/scala/kafka/controller |
1519 | 114 | 8 | 2916 | 196 |
| ControllerChannelManager.scala in core/src/main/scala/kafka/controller |
569 | 22 | 74 | 2916 | 132 |
Files Not Recently Changed (Top 50)
| File | # lines | # units | last modified (days ago) | created (days ago) | # changes |
|---|---|---|---|---|---|
| UnknownCodecException.scala in core/src/main/scala/kafka/common |
4 | - | 3321 | 3330 | 2 |
| NoEpochForPartitionException.scala in core/src/main/scala/kafka/common |
4 | - | 3064 | 3064 | 1 |
| AdminCommandFailedException.scala in core/src/main/scala/kafka/common |
5 | - | 2894 | 2894 | 1 |
| StateChangeFailedException.scala in core/src/main/scala/kafka/common |
5 | - | 2894 | 2916 | 2 |
| AdminOperationException.scala in core/src/main/scala/kafka/admin |
5 | - | 2745 | 2745 | 1 |
| ThreadShutdownException.scala in core/src/main/scala/kafka/common |
3 | - | 2440 | 2440 | 1 |
| LogCleaningAbortedException.scala in core/src/main/scala/kafka/common |
3 | - | 2440 | 2440 | 1 |
| ClientIdAndBroker.scala in core/src/main/scala/kafka/common |
9 | 1 | 2124 | 2826 | 2 |
| ClientIdAndTopic.scala in core/src/main/scala/kafka/common |
9 | 1 | 2124 | 2826 | 2 |
| InconsistentBrokerIdException.scala in core/src/main/scala/kafka/common |
6 | - | 2070 | 2070 | 1 |
| GenerateBrokerIdException.scala in core/src/main/scala/kafka/common |
6 | - | 2070 | 2070 | 1 |
| BrokerEndPointNotAvailableException.scala in core/src/main/scala/kafka/common |
4 | - | 1987 | 1987 | 1 |
| CleanerConfig.scala in core/src/main/scala/kafka/log |
11 | - | 1966 | 2784 | 4 |
| TopicAlreadyMarkedForDeletionException.scala in core/src/main/scala/kafka/common |
3 | - | 1884 | 1884 | 1 |
| BaseEnum.scala in core/src/main/scala/kafka/common |
4 | - | 1808 | 1808 | 1 |
| LongRef.scala in core/src/main/scala/kafka/common |
30 | 6 | 1662 | 1662 | 1 |
| BrokerMetadata.scala in core/src/main/scala/kafka/admin |
2 | - | 1642 | 1642 | 1 |
| RackAwareMode.scala in core/src/main/scala/kafka/admin |
7 | - | 1642 | 1642 | 1 |
| TimingWheel.scala in core/src/main/scala/kafka/utils/timer |
49 | 3 | 1613 | 1984 | 4 |
| NotNothing.scala in core/src/main/scala/kafka/utils |
8 | - | 1296 | 1296 | 1 |
| Mode.java in clients/src/main/java/org/apache/kafka/common/network |
2 | - | 1292 | 1789 | 4 |
| Callback.java in connect/runtime/src/main/java/org/apache/kafka/connect/util |
4 | - | 1292 | 1770 | 2 |
| OffsetResetStrategy.java in clients/src/main/java/org/apache/kafka/clients/consumer |
4 | - | 1292 | 1908 | 2 |
| RequestCompletionHandler.java in clients/src/main/java/org/apache/kafka/clients |
4 | - | 1292 | 2071 | 2 |
| ConnectorContext.java in connect/api/src/main/java/org/apache/kafka/connect/connector |
5 | - | 1292 | 1770 | 4 |
| TargetState.java in connect/runtime/src/main/java/org/apache/kafka/connect/runtime |
5 | - | 1292 | 1606 | 2 |
| KTableValueGetterSupplier.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
5 | - | 1292 | 1744 | 3 |
| Configurable.java in clients/src/main/java/org/apache/kafka/common |
5 | - | 1292 | 2410 | 4 |
| RequestFutureListener.java in clients/src/main/java/org/apache/kafka/clients/consumer/internals |
5 | - | 1292 | 1886 | 2 |
| NoAvailableBrokersException.java in clients/src/main/java/org/apache/kafka/clients/consumer/internals |
5 | - | 1292 | 1886 | 2 |
| NotLeaderException.java in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed |
6 | 1 | 1292 | 1770 | 3 |
| NotAssignedException.java in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed |
6 | 1 | 1292 | 1608 | 2 |
| PeekingKeyValueIterator.java in streams/src/main/java/org/apache/kafka/streams/state/internals |
6 | - | 1292 | 1457 | 3 |
| HasNextCondition.java in streams/src/main/java/org/apache/kafka/streams/state/internals |
6 | - | 1292 | 1345 | 2 |
| KStreamAggProcessorSupplier.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
6 | - | 1292 | 1657 | 2 |
| KTableProcessorSupplier.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
6 | - | 1292 | 1744 | 5 |
| Task.java in connect/api/src/main/java/org/apache/kafka/connect/connector |
7 | - | 1292 | 1770 | 3 |
| OffsetStorageReader.java in connect/api/src/main/java/org/apache/kafka/connect/storage |
7 | - | 1292 | 1770 | 3 |
| BadRequestException.java in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/rest/errors |
7 | 1 | 1292 | 1400 | 2 |
| RebalanceNeededException.java in connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed |
7 | 1 | 1292 | 1606 | 2 |
| SinkUtils.java in connect/runtime/src/main/java/org/apache/kafka/connect/util |
7 | 2 | 1292 | 1400 | 2 |
| NotEnoughReplicasAfterAppendException.java in clients/src/main/java/org/apache/kafka/common/errors |
7 | 1 | 1292 | 2165 | 4 |
| InvalidRequiredAcksException.java in clients/src/main/java/org/apache/kafka/common/errors |
7 | 1 | 1292 | 2038 | 2 |
| NoMatchingRule.java in clients/src/main/java/org/apache/kafka/common/security/kerberos |
7 | - | 1292 | 1789 | 2 |
| Cache.java in clients/src/main/java/org/apache/kafka/common/cache |
7 | - | 1292 | 1803 | 3 |
| RequestFutureAdapter.java in clients/src/main/java/org/apache/kafka/clients/consumer/internals |
7 | 1 | 1292 | 1886 | 2 |
| ProducerInterceptor.java in clients/src/main/java/org/apache/kafka/clients/producer |
7 | - | 1292 | 1677 | 4 |
| StateStoreProvider.java in streams/src/main/java/org/apache/kafka/streams/state/internals |
8 | - | 1292 | 1516 | 3 |
| SimpleConfig.java in connect/transforms/src/main/java/org/apache/kafka/connect/transforms/util |
9 | 1 | 1292 | 1339 | 2 |
| AuthorizationException.java in clients/src/main/java/org/apache/kafka/common/errors |
9 | 2 | 1292 | 1780 | 4 |
Most Recently Created Files (Top 50)
| File | # lines | # units | last modified (days ago) | created (days ago) | # changes |
|---|---|---|---|---|---|
| ActionQueue.scala in core/src/main/scala/kafka/server |
22 | 1 | 2 | 2 | 1 |
| DescribeUserScramCredentialsResult.java in clients/src/main/java/org/apache/kafka/clients/admin |
83 | 2 | 8 | 8 | 1 |
| AlterUserScramCredentialsRequest.java in clients/src/main/java/org/apache/kafka/common/requests |
69 | 8 | 8 | 8 | 1 |
| DescribeUserScramCredentialsRequest.java in clients/src/main/java/org/apache/kafka/common/requests |
54 | 8 | 8 | 8 | 1 |
| AlterUserScramCredentialsResponse.java in clients/src/main/java/org/apache/kafka/common/requests |
41 | 8 | 8 | 8 | 1 |
| DescribeUserScramCredentialsResponse.java in clients/src/main/java/org/apache/kafka/common/requests |
41 | 8 | 8 | 8 | 1 |
| UserScramCredentialsDescription.java in clients/src/main/java/org/apache/kafka/clients/admin |
38 | 6 | 8 | 8 | 1 |
| ScramCredentialInfo.java in clients/src/main/java/org/apache/kafka/clients/admin |
35 | 6 | 8 | 8 | 1 |
| UserScramCredentialUpsertion.java in clients/src/main/java/org/apache/kafka/clients/admin |
34 | 4 | 8 | 8 | 1 |
| ScramMechanism.java in clients/src/main/java/org/apache/kafka/clients/admin |
30 | 5 | 8 | 8 | 1 |
| ResourceNotFoundException.java in clients/src/main/java/org/apache/kafka/common/errors |
22 | 5 | 8 | 8 | 1 |
| DuplicateResourceException.java in clients/src/main/java/org/apache/kafka/common/errors |
22 | 5 | 8 | 8 | 1 |
| AlterUserScramCredentialsResult.java in clients/src/main/java/org/apache/kafka/clients/admin |
20 | 2 | 8 | 8 | 1 |
| UserScramCredentialDeletion.java in clients/src/main/java/org/apache/kafka/clients/admin |
12 | 2 | 8 | 8 | 1 |
| UserScramCredentialAlteration.java in clients/src/main/java/org/apache/kafka/clients/admin |
11 | 2 | 8 | 8 | 1 |
| UnacceptableCredentialException.java in clients/src/main/java/org/apache/kafka/common/errors |
10 | 2 | 8 | 8 | 1 |
| AlterUserScramCredentialsOptions.java in clients/src/main/java/org/apache/kafka/clients/admin |
6 | - | 8 | 8 | 1 |
| DescribeUserScramCredentialsOptions.java in clients/src/main/java/org/apache/kafka/clients/admin |
6 | - | 8 | 8 | 1 |
| MissingSourceTopicException.java in streams/src/main/java/org/apache/kafka/streams/errors |
7 | 1 | 9 | 9 | 1 |
| Serdes.scala in streams/streams-scala/src/main/scala/org/apache/kafka/streams/scala/serialization |
63 | 4 | 10 | 10 | 1 |
| KStreamSlidingWindowAggregate.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
349 | 16 | 3 | 12 | 2 |
| SlidingWindowedKStreamImpl.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
190 | 1 | 12 | 12 | 1 |
| SlidingWindowedCogroupedKStreamImpl.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
113 | - | 12 | 12 | 1 |
| JsonConverterGenerator.java in generator/src/main/java/org/apache/kafka/message |
373 | 9 | 17 | 17 | 1 |
| MessageClassGenerator.java in generator/src/main/java/org/apache/kafka/message |
6 | - | 17 | 17 | 1 |
| DirectoryConfigProvider.java in clients/src/main/java/org/apache/kafka/common/config/provider |
59 | 6 | 21 | 21 | 1 |
| SubscriptionStateBenchmark.java in jmh-benchmarks/src/main/java/org/apache/kafka/jmh/consumer |
69 | 4 | 22 | 22 | 1 |
| QuotaUtils.scala in core/src/main/scala/kafka/utils |
22 | 3 | 26 | 26 | 1 |
| BlockBasedTableConfigWithAccessibleCache.java in streams/src/main/java/org/apache/kafka/streams/state/internals |
14 | 2 | 30 | 30 | 1 |
| InvalidProducerEpochException.java in clients/src/main/java/org/apache/kafka/common/internals |
8 | 1 | 31 | 31 | 1 |
| ProcessorContextReverseAdapter.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
188 | 40 | 34 | 34 | 1 |
| ProcessorContextAdapter.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
177 | 37 | 3 | 34 | 3 |
| ProcessorContext.java in streams/src/main/java/org/apache/kafka/streams/processor/api |
40 | - | 3 | 34 | 3 |
| ProcessorAdapter.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
37 | 6 | 3 | 34 | 3 |
| InternalApiProcessorContext.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
36 | 1 | 34 | 34 | 1 |
| Processor.java in streams/src/main/java/org/apache/kafka/streams/processor/api |
10 | 2 | 34 | 34 | 1 |
| ProcessorSupplier.java in streams/src/main/java/org/apache/kafka/streams/processor/api |
7 | - | 34 | 34 | 1 |
| TokenBucket.java in clients/src/main/java/org/apache/kafka/common/metrics/stats |
44 | 6 | 37 | 37 | 1 |
| MetricsUtils.java in clients/src/main/java/org/apache/kafka/common/metrics/internals |
24 | 1 | 37 | 37 | 1 |
| FetchRequestBenchmark.java in jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common |
94 | 6 | 44 | 44 | 1 |
| FetchResponseBenchmark.java in jmh-benchmarks/src/main/java/org/apache/kafka/jmh/common |
75 | 3 | 44 | 44 | 1 |
| RecordsWritable.java in clients/src/main/java/org/apache/kafka/common/protocol |
71 | 11 | 44 | 44 | 1 |
| RecordsReadable.java in clients/src/main/java/org/apache/kafka/common/protocol |
54 | 10 | 44 | 44 | 1 |
| ReplicaInfo.java in clients/src/main/java/org/apache/kafka/clients/admin |
28 | 5 | 44 | 44 | 1 |
| LogDirDescription.java in clients/src/main/java/org/apache/kafka/clients/admin |
26 | 4 | 44 | 44 | 1 |
| BrokerToControllerChannelManager.scala in core/src/main/scala/kafka/server |
143 | 6 | 45 | 45 | 1 |
| StreamsNotStartedException.java in streams/src/main/java/org/apache/kafka/streams/errors |
12 | 2 | 17 | 51 | 2 |
| InvalidStateStorePartitionException.java in streams/src/main/java/org/apache/kafka/streams/errors |
11 | 2 | 51 | 51 | 1 |
| UnknownStateStoreException.java in streams/src/main/java/org/apache/kafka/streams/errors |
10 | 2 | 51 | 51 | 1 |
| StateStoreNotAvailableException.java in streams/src/main/java/org/apache/kafka/streams/errors |
10 | 2 | 51 | 51 | 1 |
Most Recently 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 |
| Log.scala in core/src/main/scala/kafka/log |
1638 | 88 | 2 | 3330 | 234 |
| ReplicaManager.scala in core/src/main/scala/kafka/server |
1383 | 55 | 2 | 3095 | 250 |
| GroupMetadataManager.scala in core/src/main/scala/kafka/coordinator/group |
1157 | 48 | 2 | 1235 | 64 |
| GroupCoordinator.scala in core/src/main/scala/kafka/coordinator/group |
1049 | 56 | 2 | 1235 | 59 |
| AbstractCoordinator.java in clients/src/main/java/org/apache/kafka/clients/consumer/internals |
1047 | 75 | 2 | 1788 | 109 |
| ConsumerCoordinator.java in clients/src/main/java/org/apache/kafka/clients/consumer/internals |
1046 | 46 | 2 | 1788 | 128 |
| KafkaConsumer.java in clients/src/main/java/org/apache/kafka/clients/consumer |
879 | 63 | 2 | 2307 | 228 |
| Partition.scala in core/src/main/scala/kafka/cluster |
827 | 51 | 2 | 3330 | 174 |
| StreamThread.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
725 | 44 | 2 | 1814 | 232 |
| DelayedOperation.scala in core/src/main/scala/kafka/server |
208 | 17 | 2 | 2109 | 26 |
| Kibosh.java in tools/src/main/java/org/apache/kafka/trogdor/fault |
144 | 19 | 2 | 1031 | 3 |
| StructRegistry.java in generator/src/main/java/org/apache/kafka/message |
129 | 9 | 2 | 438 | 4 |
| Heartbeat.java in clients/src/main/java/org/apache/kafka/clients/consumer/internals |
94 | 15 | 2 | 2071 | 14 |
| DelayedJoin.scala in core/src/main/scala/kafka/coordinator/group |
39 | 3 | 2 | 1235 | 7 |
| ActionQueue.scala in core/src/main/scala/kafka/server |
22 | 1 | 2 | 2 | 1 |
| InternalTopologyBuilder.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
1614 | 137 | 3 | 1146 | 67 |
| KStreamImpl.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
1159 | 84 | 3 | 1814 | 109 |
| KTableImpl.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
947 | 60 | 3 | 1744 | 97 |
| ImplicitLinkedHashCollection.java in clients/src/main/java/org/apache/kafka/common/utils |
401 | 52 | 3 | 492 | 6 |
| InternalStreamsBuilder.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
386 | 27 | 3 | 1139 | 37 |
| KStreamSlidingWindowAggregate.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
349 | 16 | 3 | 12 | 2 |
| Topology.java in streams/src/main/java/org/apache/kafka/streams |
309 | 31 | 3 | 1142 | 14 |
| ProcessorContextAdapter.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
177 | 37 | 3 | 34 | 3 |
| KTableKTableJoinNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
174 | 20 | 3 | 817 | 10 |
| KStreamImplJoin.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals |
157 | 3 | 3 | 346 | 5 |
| TableSourceNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
132 | 14 | 3 | 817 | 12 |
| StreamStreamJoinNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
128 | 16 | 3 | 817 | 4 |
| BaseRepartitionNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
108 | 14 | 3 | 817 | 7 |
| GroupedTableOperationRepartitionNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
89 | 9 | 3 | 817 | 7 |
| OptimizableRepartitionNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
84 | 8 | 3 | 817 | 9 |
| UnoptimizableRepartitionNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
75 | 5 | 3 | 155 | 2 |
| Log4jController.scala in core/src/main/scala/kafka/utils |
68 | 5 | 3 | 2940 | 7 |
| StatefulProcessorNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
66 | 5 | 3 | 817 | 10 |
| GraphGraceSearchUtil.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
65 | 4 | 3 | 719 | 4 |
| ProcessorParameters.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
55 | 8 | 3 | 817 | 5 |
| BaseJoinProcessorNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
54 | 7 | 3 | 817 | 4 |
| TableProcessorNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
50 | 4 | 3 | 817 | 11 |
| ProcessorContext.java in streams/src/main/java/org/apache/kafka/streams/processor |
40 | - | 3 | 1814 | 34 |
| ProcessorContext.java in streams/src/main/java/org/apache/kafka/streams/processor/api |
40 | - | 3 | 34 | 3 |
| StreamToTableNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
39 | 3 | 3 | 226 | 3 |
| ProcessorAdapter.java in streams/src/main/java/org/apache/kafka/streams/processor/internals |
37 | 6 | 3 | 34 | 3 |
| TopologyDescription.java in streams/src/main/java/org/apache/kafka/streams |
37 | - | 3 | 1146 | 8 |
| StreamTableJoinNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
35 | 3 | 3 | 817 | 4 |
| ProcessorGraphNode.java in streams/src/main/java/org/apache/kafka/streams/kstream/internals/graph |
27 | 5 | 3 | 773 | 5 |
| ConnectedStoreProvider.java in streams/src/main/java/org/apache/kafka/streams/processor |
14 | - | 3 | 108 | 2 |
| LogSegment.scala in core/src/main/scala/kafka/log |
400 | 31 | 4 | 2896 | 89 |
| KafkaAdminClient.java in clients/src/main/java/org/apache/kafka/clients/admin |
3377 | 119 | 8 | 1230 | 128 |
| KafkaController.scala in core/src/main/scala/kafka/controller |
1519 | 114 | 8 | 2916 | 196 |
| AdminManager.scala in core/src/main/scala/kafka/server |
1039 | 34 | 8 | 1523 | 55 |