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=" 7 ", penwidth="7", color="#00688bC9"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 6 ", 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/GroupMetadataManager.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[core/src/main/scala/kafka/server/KafkaApis.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[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=" 5 ", penwidth="5", color="#00688bA5"]; "[core/src/main/scala/kafka/server/DynamicBrokerConfig.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[core/src/main/scala/kafka/server/ControllerApis.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[core/src/main/scala/kafka/server/KafkaApis.scala]" -- "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/scala/kafka/network/SocketServer.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/tools/TestRaftServer.scala]" -- "[core/src/main/scala/kafka/network/SocketServer.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java]" -- "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/KafkaConfig.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ControllerApis.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/Admin.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/scala/kafka/server/DynamicBrokerConfig.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/network/SocketServer.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/ShareFetchResponse.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ControllerApis.scala]" -- "[core/src/main/scala/kafka/server/ControllerServer.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[clients/src/main/java/org/apache/kafka/clients/admin/Admin.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[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=" 3 ", penwidth="3", color="#00688b82"]; "[clients/src/main/java/org/apache/kafka/clients/admin/ForwardingAdmin.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/tools/TestRaftServer.scala]" -- "[core/src/main/scala/kafka/server/ControllerServer.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/KafkaConfig.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/scala/kafka/server/KafkaConfig.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ControllerServer.scala]" -- "[core/src/main/scala/kafka/server/KafkaApis.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ReplicaManager.scala]" -- "[core/src/main/scala/kafka/cluster/Partition.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/server/ControllerApis.scala]" -- "[core/src/main/java/kafka/server/builders/KafkaApisBuilder.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java]" -- "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorService.java]" -- "[clients/src/main/java/org/apache/kafka/clients/admin/KafkaAdminClient.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[core/src/main/scala/kafka/tools/TestRaftServer.scala]" -- "[core/src/main/scala/kafka/server/BrokerServer.scala]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[clients/src/main/java/org/apache/kafka/common/requests/UpdateFeaturesResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java]" -- "[clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/FetchSnapshotResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/DescribeTransactionsResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/OffsetsForLeaderEpochResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/ConsumerGroupDescribeResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/DescribeShareGroupOffsetsResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/VoteResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/ElectLeadersResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/IncrementalAlterConfigsResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/BeginQuorumEpochResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/StreamsGroupDescribeResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/ReadShareGroupStateResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/AlterShareGroupOffsetsResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/CreateTopicsResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/ProduceResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/PushTelemetryResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/DescribeTopicPartitionsResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[core/src/main/scala/kafka/server/ReplicaManager.scala]" -- "[core/src/main/scala/kafka/coordinator/transaction/TransactionStateManager.scala]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/ShareGroupDescribeResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/BrokerHeartbeatResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[clients/src/main/java/org/apache/kafka/common/requests/InitializeShareGroupStateResponse.java]" -- "[clients/src/main/java/org/apache/kafka/common/requests/AlterClientQuotasResponse.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; }