graph G { compound="true" rankdir="TB" bgcolor="white" fontname="Tahoma" node [ fixedsize="false" fontname="Tahoma" color="white" fillcolor="deepskyblue2" fontcolor="black" shape="box" style="filled" penwidth="1.0" ] edge [ fontname="Arial" color="#00688b" fontcolor="black" fontsize="12" arrowsize="0.5" penwidth="1.0" ] "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java]" [label=" 20 ", penwidth="10", color="#00688bFF"]; "[streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java]" -- "[streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java]" [label=" 17 ", penwidth="8", color="#00688bDB"]; "[core/src/main/scala/kafka/server/ReplicaManager.scala]" -- "[core/src/main/scala/kafka/cluster/Partition.scala]" [label=" 16 ", penwidth="8", color="#00688bDB"]; "[clients/src/main/java/org/apache/kafka/clients/admin/Admin.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java]" [label=" 15 ", penwidth="7", color="#00688bC9"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" [label=" 14 ", penwidth="7", color="#00688bC9"]; "[clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/Admin.java]" [label=" 13 ", penwidth="6", color="#00688bB7"]; "[clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java]" [label=" 13 ", penwidth="6", color="#00688bB7"]; "[core/src/main/scala/kafka/server/KafkaApis.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 13 ", penwidth="6", color="#00688bB7"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 12 ", penwidth="6", color="#00688bB7"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" [label=" 12 ", penwidth="6", color="#00688bB7"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/consumer/ConsumerGroup.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java]" [label=" 11 ", penwidth="5", color="#00688bA5"]; "[core/src/main/scala/kafka/server/ReplicaManager.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 11 ", penwidth="5", color="#00688bA5"]; "[core/src/main/scala/kafka/server/KafkaApis.scala]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" [label=" 10 ", penwidth="5", color="#00688bA5"]; "[core/src/main/scala/kafka/server/KafkaConfig.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 9 ", penwidth="4", color="#00688b93"]; "[share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorService.java]" -- "[share-coordinator/src/main/java/org/apache/kafka/coordinator/share/ShareCoordinatorShard.java]" [label=" 9 ", penwidth="4", color="#00688b93"]; "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/events/ApplicationEventProcessor.java]" -- "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java]" [label=" 9 ", penwidth="4", color="#00688b93"]; "[metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java]" -- "[metadata/src/main/java/org/apache/kafka/controller/QuorumController.java]" [label=" 9 ", penwidth="4", color="#00688b93"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" [label=" 9 ", penwidth="4", color="#00688b93"]; "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 9 ", penwidth="4", color="#00688b93"]; "[core/src/main/java/kafka/server/share/ShareFetchUtils.java]" -- "[core/src/main/java/kafka/server/share/SharePartition.java]" [label=" 9 ", penwidth="4", color="#00688b93"]; "[core/src/main/scala/kafka/server/KafkaConfig.scala]" -- "[core/src/main/scala/kafka/server/DynamicBrokerConfig.scala]" [label=" 9 ", penwidth="4", color="#00688b93"]; "[core/src/main/scala/kafka/log/LogManager.scala]" -- "[core/src/main/scala/kafka/server/ReplicaManager.scala]" [label=" 8 ", penwidth="4", color="#00688b93"]; "[core/src/main/scala/kafka/server/DynamicBrokerConfig.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 8 ", penwidth="4", color="#00688b93"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/KRaftMetadataRequestBenchmark.java]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 8 ", penwidth="4", color="#00688b93"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java]" [label=" 8 ", penwidth="4", color="#00688b93"]; "[core/src/main/java/kafka/server/share/SharePartitionManager.java]" -- "[core/src/main/java/kafka/server/share/SharePartition.java]" [label=" 8 ", penwidth="4", color="#00688b93"]; "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 8 ", penwidth="4", color="#00688b93"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java]" [label=" 8 ", penwidth="4", color="#00688b93"]; "[core/src/main/scala/kafka/server/ReplicaManager.scala]" -- "[core/src/main/scala/kafka/server/KafkaConfig.scala]" [label=" 7 ", penwidth="3", color="#00688b82"]; "[raft/src/main/java/org/apache/kafka/raft/QuorumState.java]" -- "[raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java]" [label=" 7 ", penwidth="3", color="#00688b82"]; "[clients/src/main/java/org/apache/kafka/common/requests/AbstractRequest.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java]" [label=" 7 ", penwidth="3", color="#00688b82"]; "[metadata/src/main/java/org/apache/kafka/controller/FeatureControlManager.java]" -- "[metadata/src/main/java/org/apache/kafka/controller/QuorumController.java]" [label=" 7 ", penwidth="3", color="#00688b82"]; "[server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java]" -- "[core/src/main/scala/kafka/server/KafkaConfig.scala]" [label=" 7 ", penwidth="3", color="#00688b82"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinator.java]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 7 ", penwidth="3", color="#00688b82"]; "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java]" -- "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java]" [label=" 7 ", penwidth="3", color="#00688b82"]; "[core/src/main/java/kafka/server/share/SharePartition.java]" -- "[core/src/main/java/kafka/server/share/DelayedShareFetch.java]" [label=" 7 ", penwidth="3", color="#00688b82"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/KRaftMetadataRequestBenchmark.java]" -- "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" [label=" 7 ", penwidth="3", color="#00688b82"]; "[core/src/main/java/kafka/server/share/SharePartitionManager.java]" -- "[core/src/main/java/kafka/server/share/DelayedShareFetch.java]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[clients/src/main/java/org/apache/kafka/clients/consumer/MockConsumer.java]" -- "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[streams/src/main/java/org/apache/kafka/streams/Topology.java]" -- "[streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopologyBuilder.java]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/KafkaApis.scala]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java]" -- "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/classic/ClassicGroup.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[clients/src/main/java/org/apache/kafka/common/protocol/ApiKeys.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/metadata/KRaftMetadataCache.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/KafkaConfig.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java]" -- "[core/src/main/scala/kafka/log/LogManager.scala]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/UpdateFollowerFetchStateBenchmark.java]" -- "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/partition/PartitionMakeFollowerBenchmark.java]" [label=" 6 ", penwidth="3", color="#00688b82"]; "[raft/src/main/java/org/apache/kafka/raft/LeaderState.java]" -- "[raft/src/main/java/org/apache/kafka/raft/QuorumState.java]" [label=" 6 ", penwidth="3", color="#00688b82"]; }