apache / kafka
Temporal 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).


Files Most Frequently Changed Together (Top 50)

data...

Pairs # same commits # commits 1 # commits 2 latest commit
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java
7 135 (5%) 74 (9%) 2025-04-25
core/src/main/scala/kafka/server/ControllerServer.scala
core/src/main/scala/kafka/server/BrokerServer.scala
6 116 (5%) 216 (2%) 2025-04-30
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
5 59 (8%) 135 (3%) 2025-04-25
core/src/main/scala/kafka/server/KafkaApis.scala
core/src/main/scala/kafka/server/BrokerServer.scala
5 742 (<1%) 216 (2%) 2025-05-01
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java
5 59 (8%) 74 (6%) 2025-04-25
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala
core/src/main/scala/kafka/server/BrokerServer.scala
4 119 (3%) 216 (1%) 2025-05-06
core/src/main/scala/kafka/server/ControllerApis.scala
core/src/main/scala/kafka/server/KafkaApis.scala
4 66 (6%) 742 (<1%) 2025-04-15
core/src/main/java/kafka/server/builders/KafkaApisBuilder.java
core/src/main/scala/kafka/server/BrokerServer.scala
4 25 (16%) 216 (1%) 2025-04-30
core/src/main/java/kafka/server/builders/KafkaApisBuilder.java
core/src/main/scala/kafka/server/KafkaApis.scala
4 25 (16%) 742 (<1%) 2025-04-30
core/src/main/scala/kafka/server/KafkaApis.scala
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java
3 742 (<1%) 74 (4%) 2025-04-25
core/src/main/scala/kafka/server/ControllerServer.scala
core/src/main/scala/kafka/network/SocketServer.scala
3 116 (2%) 209 (1%) 2025-04-30
core/src/main/scala/kafka/tools/TestRaftServer.scala
core/src/main/scala/kafka/network/SocketServer.scala
3 56 (5%) 209 (1%) 2025-04-30
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java
3 386 (<1%) 11 (27%) 2025-04-30
core/src/main/scala/kafka/server/KafkaConfig.scala
core/src/main/scala/kafka/server/KafkaApis.scala
3 511 (<1%) 742 (<1%) 2025-04-30
core/src/main/scala/kafka/server/ControllerApis.scala
core/src/main/scala/kafka/server/BrokerServer.scala
3 66 (4%) 216 (1%) 2025-04-15
clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
3 21 (14%) 71 (4%) 2025-04-25
core/src/main/scala/kafka/server/ControllerServer.scala
core/src/main/scala/kafka/server/DynamicBrokerConfig.scala
3 116 (2%) 119 (2%) 2025-04-30
core/src/main/scala/kafka/network/SocketServer.scala
core/src/main/scala/kafka/server/BrokerServer.scala
3 209 (1%) 216 (1%) 2025-04-30
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java
clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java
3 67 (4%) 9 (33%) 2025-04-24
core/src/main/scala/kafka/server/ControllerApis.scala
core/src/main/scala/kafka/server/ControllerServer.scala
3 66 (4%) 116 (2%) 2025-04-15
clients/src/main/java/org/apache/kafka/clients/admin/Admin.java
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
3 71 (4%) 281 (1%) 2025-04-25
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java
3 5 (60%) 11 (27%) 2025-04-30
clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
3 21 (14%) 281 (1%) 2025-04-25
core/src/main/scala/kafka/tools/TestRaftServer.scala
core/src/main/scala/kafka/server/ControllerServer.scala
3 56 (5%) 116 (2%) 2025-04-30
core/src/main/scala/kafka/server/KafkaConfig.scala
core/src/main/scala/kafka/server/BrokerServer.scala
3 511 (<1%) 216 (1%) 2025-04-30
core/src/main/scala/kafka/server/ControllerServer.scala
core/src/main/java/kafka/server/builders/KafkaApisBuilder.java
3 116 (2%) 25 (12%) 2025-04-15
core/src/main/scala/kafka/server/ControllerServer.scala
core/src/main/scala/kafka/server/KafkaConfig.scala
3 116 (2%) 511 (<1%) 2025-04-30
core/src/main/scala/kafka/server/ControllerServer.scala
core/src/main/scala/kafka/server/KafkaApis.scala
3 116 (2%) 742 (<1%) 2025-04-15
core/src/main/scala/kafka/server/ReplicaManager.scala
core/src/main/scala/kafka/cluster/Partition.scala
3 484 (<1%) 310 (<1%) 2025-04-27
core/src/main/scala/kafka/server/ControllerApis.scala
core/src/main/java/kafka/server/builders/KafkaApisBuilder.java
3 66 (4%) 25 (12%) 2025-04-15
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java
3 386 (<1%) 5 (60%) 2025-04-30
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java
clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java
3 74 (4%) 281 (1%) 2025-05-06
core/src/main/scala/kafka/tools/TestRaftServer.scala
core/src/main/scala/kafka/server/BrokerServer.scala
3 56 (5%) 216 (1%) 2025-04-30
clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesResponse.java
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java
2 8 (25%) 54 (3%) 2025-04-24
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java
2 189 (1%) 52 (3%) 2025-04-27
clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotResponse.java
clients/src/main/java/org/apache/kafka/common/requests/DescribeTransactionsResponse.java
2 9 (22%) 5 (40%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java
clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java
2 19 (10%) 4 (50%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java
2 4 (50%) 118 (1%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/DescribeShareGroupOffsetsResponse.java
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java
2 4 (50%) 23 (8%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatResponse.java
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java
2 4 (50%) 118 (1%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/VoteResponse.java
clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java
2 8 (25%) 9 (22%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java
clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochResponse.java
2 9 (22%) 8 (25%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/StreamsGroupDescribeResponse.java
clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateResponse.java
2 4 (50%) 4 (50%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeResponse.java
clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java
2 4 (50%) 4 (50%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryResponse.java
clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsResponse.java
2 4 (50%) 3 (66%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java
clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java
2 23 (8%) 54 (3%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryResponse.java
clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java
2 4 (50%) 4 (50%) 2025-04-24
core/src/main/scala/kafka/server/ReplicaManager.scala
core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala
2 484 (<1%) 91 (2%) 2025-04-29
clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeResponse.java
clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatResponse.java
2 4 (50%) 4 (50%) 2025-04-24
clients/src/main/java/org/apache/kafka/common/requests/InitializeShareGroupStateResponse.java
clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java
2 4 (50%) 8 (25%) 2025-04-24
Dependencies between files in same commits
The number on the lines shows the number of shared commits.
G [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java] [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java] [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java] [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java] [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java]--[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java] 7 [clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java] [clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java] [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]--[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java] 3 [core/src/main/scala/kafka/server/ControllerServer.scala] [core/src/main/scala/kafka/server/ControllerServer.scala] [core/src/main/scala/kafka/server/BrokerServer.scala] [core/src/main/scala/kafka/server/BrokerServer.scala] [core/src/main/scala/kafka/server/ControllerServer.scala]--[core/src/main/scala/kafka/server/BrokerServer.scala] 6 [core/src/main/scala/kafka/server/KafkaApis.scala] [core/src/main/scala/kafka/server/KafkaApis.scala] [core/src/main/scala/kafka/server/ControllerServer.scala]--[core/src/main/scala/kafka/server/KafkaApis.scala] 3 [core/src/main/scala/kafka/server/DynamicBrokerConfig.scala] [core/src/main/scala/kafka/server/DynamicBrokerConfig.scala] [core/src/main/scala/kafka/server/ControllerServer.scala]--[core/src/main/scala/kafka/server/DynamicBrokerConfig.scala] 3 [core/src/main/java/kafka/server/builders/KafkaApisBuilder.java] [core/src/main/java/kafka/server/builders/KafkaApisBuilder.java] [core/src/main/scala/kafka/server/ControllerServer.scala]--[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java] 3 [core/src/main/scala/kafka/network/SocketServer.scala] [core/src/main/scala/kafka/network/SocketServer.scala] [core/src/main/scala/kafka/server/ControllerServer.scala]--[core/src/main/scala/kafka/network/SocketServer.scala] 3 [core/src/main/scala/kafka/server/KafkaConfig.scala] [core/src/main/scala/kafka/server/KafkaConfig.scala] [core/src/main/scala/kafka/server/ControllerServer.scala]--[core/src/main/scala/kafka/server/KafkaConfig.scala] 3 [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java] [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java] [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java]--[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java] 5 [group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java]--[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java] 5 [core/src/main/scala/kafka/server/KafkaApis.scala]--[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java] 3 [core/src/main/scala/kafka/server/KafkaApis.scala]--[core/src/main/scala/kafka/server/BrokerServer.scala] 5 [core/src/main/scala/kafka/server/DynamicBrokerConfig.scala]--[core/src/main/scala/kafka/server/BrokerServer.scala] 4 [core/src/main/scala/kafka/server/ControllerApis.scala] [core/src/main/scala/kafka/server/ControllerApis.scala] [core/src/main/scala/kafka/server/ControllerApis.scala]--[core/src/main/scala/kafka/server/ControllerServer.scala] 3 [core/src/main/scala/kafka/server/ControllerApis.scala]--[core/src/main/scala/kafka/server/BrokerServer.scala] 3 [core/src/main/scala/kafka/server/ControllerApis.scala]--[core/src/main/scala/kafka/server/KafkaApis.scala] 4 [core/src/main/scala/kafka/server/ControllerApis.scala]--[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java] 3 [core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]--[core/src/main/scala/kafka/server/BrokerServer.scala] 4 [core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]--[core/src/main/scala/kafka/server/KafkaApis.scala] 4 [core/src/main/scala/kafka/network/SocketServer.scala]--[core/src/main/scala/kafka/server/BrokerServer.scala] 3 [core/src/main/scala/kafka/tools/TestRaftServer.scala] [core/src/main/scala/kafka/tools/TestRaftServer.scala] [core/src/main/scala/kafka/tools/TestRaftServer.scala]--[core/src/main/scala/kafka/server/ControllerServer.scala] 3 [core/src/main/scala/kafka/tools/TestRaftServer.scala]--[core/src/main/scala/kafka/server/BrokerServer.scala] 3 [core/src/main/scala/kafka/tools/TestRaftServer.scala]--[core/src/main/scala/kafka/network/SocketServer.scala] 3 [streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java] [streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java] [clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java] [clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java] [streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java]--[clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java] 3 [clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java] [clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java] [streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java]--[clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java] 3 [core/src/main/scala/kafka/server/KafkaConfig.scala]--[core/src/main/scala/kafka/server/BrokerServer.scala] 3 [core/src/main/scala/kafka/server/KafkaConfig.scala]--[core/src/main/scala/kafka/server/KafkaApis.scala] 3 [clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java] [clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java] [clients/src/main/java/org/apache/kafka/clients/admin/Admin.java] [clients/src/main/java/org/apache/kafka/clients/admin/Admin.java] [clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java]--[clients/src/main/java/org/apache/kafka/clients/admin/Admin.java] 3 [clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java]--[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java] 3 [clients/src/main/java/org/apache/kafka/clients/admin/Admin.java]--[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java] 3 [clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java] 3 [clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java]--[clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java] 3 [core/src/main/scala/kafka/server/ReplicaManager.scala] [core/src/main/scala/kafka/server/ReplicaManager.scala] [core/src/main/scala/kafka/cluster/Partition.scala] [core/src/main/scala/kafka/cluster/Partition.scala] [core/src/main/scala/kafka/server/ReplicaManager.scala]--[core/src/main/scala/kafka/cluster/Partition.scala] 3 [core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala] [core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala] [core/src/main/scala/kafka/server/ReplicaManager.scala]--[core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala] 2 [clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java] 2 [clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java] [clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java] [clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java] [clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java] [clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java]--[clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/DescribeTransactionsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/DescribeTransactionsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/DescribeTransactionsResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/DescribeShareGroupOffsetsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/DescribeShareGroupOffsetsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/DescribeShareGroupOffsetsResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/VoteResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/VoteResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/VoteResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/StreamsGroupDescribeResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/StreamsGroupDescribeResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/StreamsGroupDescribeResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsResponse.java] 2 [clients/src/main/java/org/apache/kafka/common/requests/InitializeShareGroupStateResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/InitializeShareGroupStateResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java] [clients/src/main/java/org/apache/kafka/common/requests/InitializeShareGroupStateResponse.java]--[clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java] 2
Download: SVG DOT (open online Graphviz editor)

Open 2D force graph (file dependencies)... Open 3D force graph (file dependencies)...
Open 2D force graph (file dependencies with commits)... Open 3D force graph (file dependencies with commits)...
Dependencies between components in same commits (primary)
The number on the lines shows the number of shared commits.
G clients clients clients--clients 37 core core core--clients 15 core--core 30 group-coordinator group-coordinator core--group-coordinator 11 server server server--clients 6 server--core 12 server--server 7 server-common server-common server--server-common 2 jmh-benchmarks jmh-benchmarks server--jmh-benchmarks 3 raft raft server--raft 1 group-coordinator--clients 10 group-coordinator--group-coordinator 11 tools tools tools--clients 7 tools--core 4 tools--server 2 tools--tools 4 tools--server-common 2 connect connect tools--connect 2 streams streams streams--clients 6 streams--group-coordinator 2 streams--streams 4 server-common--clients 5 server-common--core 6 server-common--group-coordinator 4 server-common--server-common 6 storage storage server-common--storage 2 metadata metadata server-common--metadata 4 server-common--raft 2 jmh-benchmarks--clients 4 jmh-benchmarks--core 6 jmh-benchmarks--jmh-benchmarks 2 storage--core 6 storage--storage 3 metadata--clients 3 metadata--core 3 metadata--group-coordinator 1 metadata--metadata 4 connect--clients 1 connect--core 1 connect--connect 3 raft--core 3 raft--tools 1 raft--metadata 2 raft--raft 3 share-coordinator share-coordinator share-coordinator--clients 1 share-coordinator--group-coordinator 2 share-coordinator--share-coordinator 2 coordinator-common coordinator-common coordinator-common--clients 1 coordinator-common--core 1 coordinator-common--group-coordinator 1
Download: SVG DOT (open online Graphviz editor)

Open 2D force graph (file dependencies)... Open 3D force graph (file dependencies)...