Apache KafkaTemporal Dependencies
A temporal dependency occurs when developers change two or more files at the same time (i.e. they are a part of the same commit).
File Change History per Logical Decomposition
primary
primary (2+ links)
Files Most Frequently Changed Together (Top 20)
| Pairs | # same commits | # commits 1 | # commits 2 |
|---|---|---|---|
| core/src/main/scala/kafka/server/ReplicaManager.scala core/src/main/scala/kafka/server/KafkaApis.scala |
126 | 276 (45%) | 457 (27%) |
| core/src/main/scala/kafka/server/ReplicaManager.scala core/src/main/scala/kafka/cluster/Partition.scala |
122 | 276 (44%) | 188 (64%) |
| core/src/main/scala/kafka/server/KafkaServer.scala core/src/main/scala/kafka/server/KafkaConfig.scala |
99 | 253 (39%) | 257 (38%) |
| core/src/main/scala/kafka/server/KafkaServer.scala core/src/main/scala/kafka/server/KafkaApis.scala |
94 | 253 (37%) | 457 (20%) |
| streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java |
88 | 259 (33%) | 177 (49%) |
| core/src/main/scala/kafka/server/ReplicaManager.scala core/src/main/scala/kafka/log/Log.scala |
87 | 276 (31%) | 257 (33%) |
| core/src/main/scala/kafka/server/KafkaApis.scala core/src/main/scala/kafka/log/Log.scala |
81 | 457 (17%) | 257 (31%) |
| core/src/main/scala/kafka/server/KafkaConfig.scala core/src/main/scala/kafka/server/KafkaApis.scala |
77 | 257 (29%) | 457 (16%) |
| core/src/main/scala/kafka/log/LogManager.scala core/src/main/scala/kafka/log/Log.scala |
76 | 139 (54%) | 257 (29%) |
| core/src/main/scala/kafka/server/KafkaApis.scala core/src/main/scala/kafka/cluster/Partition.scala |
75 | 457 (16%) | 188 (39%) |
| core/src/main/scala/kafka/log/Log.scala core/src/main/scala/kafka/cluster/Partition.scala |
73 | 257 (28%) | 188 (38%) |
| core/src/main/scala/kafka/log/LogSegment.scala core/src/main/scala/kafka/log/Log.scala |
68 | 92 (73%) | 257 (26%) |
| core/src/main/scala/kafka/server/KafkaApis.scala clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java |
68 | 457 (14%) | 85 (80%) |
| streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java |
67 | 259 (25%) | 143 (46%) |
| clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java |
65 | 143 (45%) | 262 (24%) |
| core/src/main/scala/kafka/controller/KafkaController.scala core/src/main/scala/kafka/controller/ControllerChannelManager.scala |
65 | 219 (29%) | 142 (45%) |
| core/src/main/scala/kafka/server/ReplicaManager.scala core/src/main/scala/kafka/server/KafkaServer.scala |
65 | 276 (23%) | 253 (25%) |
| clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java |
64 | 143 (44%) | 120 (53%) |
| clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java |
64 | 186 (34%) | 262 (24%) |
| core/src/main/scala/kafka/server/KafkaApis.scala core/src/main/scala/kafka/network/RequestChannel.scala |
64 | 457 (14%) | 111 (57%) |
Files from Different Folders Most Frequently Changed Together (Top 20)
| Pairs | # same commits | # commits 1 | # commits 2 |
|---|---|---|---|
| core/src/main/scala/kafka/server/ReplicaManager.scala core/src/main/scala/kafka/cluster/Partition.scala |
122 | 276 (44%) | 188 (64%) |
| core/src/main/scala/kafka/server/ReplicaManager.scala core/src/main/scala/kafka/log/Log.scala |
87 | 276 (31%) | 257 (33%) |
| core/src/main/scala/kafka/server/KafkaApis.scala core/src/main/scala/kafka/log/Log.scala |
81 | 457 (17%) | 257 (31%) |
| core/src/main/scala/kafka/server/KafkaApis.scala core/src/main/scala/kafka/cluster/Partition.scala |
75 | 457 (16%) | 188 (39%) |
| core/src/main/scala/kafka/log/Log.scala core/src/main/scala/kafka/cluster/Partition.scala |
73 | 257 (28%) | 188 (38%) |
| core/src/main/scala/kafka/server/KafkaApis.scala clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java |
68 | 457 (14%) | 85 (80%) |
| streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java |
67 | 259 (25%) | 143 (46%) |
| clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java |
65 | 143 (45%) | 262 (24%) |
| clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java |
64 | 186 (34%) | 262 (24%) |
| core/src/main/scala/kafka/server/KafkaApis.scala core/src/main/scala/kafka/network/RequestChannel.scala |
64 | 457 (14%) | 111 (57%) |
| clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java |
63 | 174 (36%) | 262 (24%) |
| core/src/main/scala/kafka/server/KafkaApis.scala clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java |
63 | 457 (13%) | 73 (86%) |
| streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java |
63 | 124 (50%) | 113 (55%) |
| clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java |
62 | 73 (84%) | 85 (72%) |
| core/src/main/scala/kafka/server/KafkaServer.scala core/src/main/scala/kafka/log/LogManager.scala |
58 | 253 (22%) | 139 (41%) |
| clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java |
57 | 132 (43%) | 186 (30%) |
| core/src/main/scala/kafka/server/KafkaApis.scala clients/src/main/java/org/apache/kafka/common/protocol/Errors.java |
57 | 457 (12%) | 98 (58%) |
| core/src/main/scala/kafka/server/KafkaServer.scala core/src/main/scala/kafka/network/SocketServer.scala |
57 | 253 (22%) | 139 (41%) |
| core/src/main/scala/kafka/server/ReplicaManager.scala core/src/main/scala/kafka/log/LogManager.scala |
57 | 276 (20%) | 139 (41%) |
| core/src/main/scala/kafka/server/KafkaApis.scala core/src/main/scala/kafka/admin/AdminUtils.scala |
54 | 457 (11%) | 99 (54%) |