KSTORAGE-2280: Added a compaction CPU Utilzation Metric (#7000)
* KSTORAGE-2280: Added a compaction CPU Utilzation Metric * Created a separate CPU metric measuring utility class * Created a separate CPU metric measuring utility class * Changed the ThreadCPUMeter class to take in immutable Seq collection * Minor comment changes * Minor format changes * Minor format changes * Minor format changes * Minor format changes * Minor format changes
显示
- core/src/main/scala/kafka/log/LogCleaner.scala 8 个添加, 0 个删除core/src/main/scala/kafka/log/LogCleaner.scala
- core/src/main/scala/kafka/tier/tasks/TierTasks.scala 12 个添加, 4 个删除core/src/main/scala/kafka/tier/tasks/TierTasks.scala
- core/src/main/scala/kafka/tier/tasks/compaction/TierLogCleanerManager.scala 2 个添加, 3 个删除...a/kafka/tier/tasks/compaction/TierLogCleanerManager.scala
- core/src/main/scala/kafka/utils/ThreadsCpuMeter.scala 66 个添加, 0 个删除core/src/main/scala/kafka/utils/ThreadsCpuMeter.scala
- core/src/test/scala/integration/kafka/tier/TierCompactionIntegrationTest.scala 5 个添加, 1 个删除...ntegration/kafka/tier/TierCompactionIntegrationTest.scala
- core/src/test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala 26 个添加, 2 个删除...test/scala/unit/kafka/log/LogCleanerIntegrationTest.scala
加载中
想要评论请 注册 或 登录