MINOR: Move `KafkaYammerMetrics` to server-common (#11970)
With major server components like the new quorum controller being moved outside of the `core` module, it is useful to have shared dependencies moved into `server-common`. An example of this is Yammer metrics which server components still rely heavily upon. All server components should have access to the default registry used by the broker so that new metrics can be registered and metric naming conventions should be standardized. This is particularly important in KRaft where we are attempting to recreate identically named metrics in the controller context. This patch takes a step in this direction. It moves `KafkaYammerMetrics` into `server-common` and it implements standard metric naming utilities there. Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>
显示
- build.gradle 1 个添加, 0 个删除build.gradle
- checkstyle/import-control.xml 5 个添加, 0 个删除checkstyle/import-control.xml
- core/src/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala 1 个添加, 0 个删除...rc/main/scala/kafka/metrics/KafkaCSVMetricsReporter.scala
- core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala 2 个添加, 1 个删除core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala
- core/src/main/scala/kafka/server/BrokerServer.scala 3 个添加, 2 个删除core/src/main/scala/kafka/server/BrokerServer.scala
- core/src/main/scala/kafka/server/ControllerServer.scala 2 个添加, 1 个删除core/src/main/scala/kafka/server/ControllerServer.scala
- core/src/main/scala/kafka/server/KafkaBroker.scala 2 个添加, 1 个删除core/src/main/scala/kafka/server/KafkaBroker.scala
- core/src/main/scala/kafka/server/KafkaRaftServer.scala 2 个添加, 1 个删除core/src/main/scala/kafka/server/KafkaRaftServer.scala
- core/src/main/scala/kafka/server/KafkaServer.scala 2 个添加, 1 个删除core/src/main/scala/kafka/server/KafkaServer.scala
- core/src/test/scala/integration/kafka/api/BaseQuotaTest.scala 2 个添加, 1 个删除.../src/test/scala/integration/kafka/api/BaseQuotaTest.scala
- core/src/test/scala/integration/kafka/api/EndToEndAuthorizationTest.scala 2 个添加, 2 个删除...ala/integration/kafka/api/EndToEndAuthorizationTest.scala
- core/src/test/scala/integration/kafka/api/MetricsTest.scala 2 个添加, 1 个删除core/src/test/scala/integration/kafka/api/MetricsTest.scala
- core/src/test/scala/integration/kafka/api/SslAdminIntegrationTest.scala 2 个添加, 1 个删除...scala/integration/kafka/api/SslAdminIntegrationTest.scala
- core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala 1 个添加, 1 个删除...ation/kafka/server/DynamicBrokerReconfigurationTest.scala
- core/src/test/scala/unit/kafka/cluster/PartitionTest.scala 2 个添加, 2 个删除core/src/test/scala/unit/kafka/cluster/PartitionTest.scala
- core/src/test/scala/unit/kafka/controller/ControllerEventManagerTest.scala 1 个添加, 1 个删除...la/unit/kafka/controller/ControllerEventManagerTest.scala
- core/src/test/scala/unit/kafka/controller/ControllerIntegrationTest.scala 2 个添加, 1 个删除...ala/unit/kafka/controller/ControllerIntegrationTest.scala
- core/src/test/scala/unit/kafka/coordinator/group/GroupMetadataManagerTest.scala 2 个添加, 2 个删除...it/kafka/coordinator/group/GroupMetadataManagerTest.scala
- core/src/test/scala/unit/kafka/coordinator/transaction/TransactionMarkerChannelManagerTest.scala 1 个添加, 1 个删除...tor/transaction/TransactionMarkerChannelManagerTest.scala
- core/src/test/scala/unit/kafka/integration/MetricsDuringTopicCreationDeletionTest.scala 1 个添加, 1 个删除.../integration/MetricsDuringTopicCreationDeletionTest.scala
加载中
想要评论请 注册 或 登录