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/GroupMetadataManager.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" [label=" 14 ", penwidth="10", color="#00688bFF"]; "[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=" 13 ", penwidth="9", color="#00688bED"]; "[clients/src/main/java/org/apache/kafka/clients/admin/Admin.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java]" [label=" 12 ", penwidth="8", color="#00688bDB"]; "[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=" 11 ", penwidth="7", color="#00688bC9"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 11 ", penwidth="7", color="#00688bC9"]; "[clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java]" [label=" 10 ", 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=" 10 ", penwidth="7", color="#00688bC9"]; "[core/src/main/scala/kafka/server/KafkaApis.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 9 ", penwidth="6", color="#00688bB7"]; "[core/src/main/scala/kafka/server/KafkaApis.scala]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" [label=" 8 ", penwidth="5", color="#00688bA5"]; "[streams/src/main/java/org/apache/kafka/streams/kstream/KStream.java]" -- "[streams/src/main/java/org/apache/kafka/streams/kstream/internals/KStreamImpl.java]" [label=" 8 ", penwidth="5", color="#00688bA5"]; "[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=" 7 ", penwidth="5", color="#00688bA5"]; "[core/src/main/scala/kafka/server/ReplicaManager.scala]" -- "[core/src/main/scala/kafka/cluster/Partition.scala]" [label=" 7 ", penwidth="5", color="#00688bA5"]; "[core/src/main/scala/kafka/server/DynamicBrokerConfig.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/StreamsGroup.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[core/src/main/scala/kafka/server/KafkaConfig.scala]" -- "[core/src/main/scala/kafka/server/DynamicBrokerConfig.scala]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 6 ", penwidth="4", color="#00688b93"]; "[server/src/main/java/org/apache/kafka/server/config/AbstractKafkaConfig.java]" -- "[core/src/main/scala/kafka/server/KafkaConfig.scala]" [label=" 5 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 5 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/KafkaConfig.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 5 ", 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=" 5 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/log/LogManager.scala]" -- "[core/src/main/scala/kafka/server/ReplicaManager.scala]" [label=" 5 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ReplicaManager.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 5 ", 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=" 5 ", penwidth="3", color="#00688b82"]; "[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=" 5 ", 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=" 5 ", penwidth="3", color="#00688b82"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java]" -- "[core/src/main/scala/kafka/cluster/Partition.scala]" [label=" 5 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/KafkaConfig.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 5 ", penwidth="3", color="#00688b82"]; "[core/src/main/java/kafka/server/share/ShareFetchUtils.java]" -- "[core/src/main/java/kafka/server/share/SharePartition.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/fetcher/ReplicaFetcherThreadBenchmark.java]" -- "[core/src/main/scala/kafka/server/ReplicaManager.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/clients/admin/AlterConsumerGroupOffsetsResult.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java]" -- "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/server/ReplicaManager.scala]" -- "[core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/java/kafka/server/share/SharePartitionManager.java]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumeRequestManager.java]" -- "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/KRaftMetadataRequestBenchmark.java]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[metadata/src/main/java/org/apache/kafka/controller/ReplicationControlManager.java]" -- "[metadata/src/main/java/org/apache/kafka/controller/QuorumController.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/server/ReplicaManager.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/server/KafkaApis.scala]" -- "[core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/KRaftMetadataRequestBenchmark.java]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[jmh-benchmarks/src/main/java/org/apache/kafka/jmh/metadata/KRaftMetadataRequestBenchmark.java]" -- "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/network/SocketServer.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/scala/kafka/server/DynamicBrokerConfig.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/server/ControllerApis.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ExactlyOnceWorkerSourceTask.java]" -- "[connect/runtime/src/main/java/org/apache/kafka/connect/runtime/ConnectorConfig.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" [label=" 4 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/server/AbstractFetcherThread.scala]" -- "[core/src/main/scala/kafka/cluster/Partition.scala]" [label=" 4 ", penwidth="2", color="#00688b70"]; }