KAFKALESS-830: Set replication bytes in/out for topics (#7023)
* KAFKALESS-830: Set replication bytes in/out for topics This change updates the replication bytes in/out at the topic level. For the replication bytes out, it makes it same as the bytes-in for the topic. For the replication bytes in, it goes over leader of all followers of a topic on a broker and sets it as sum of all leader bytes-in. A follow up PR will do similar change at broker level. Couple of name refactoring was made in the Cluster class that made this PR bigger than the small change it contains. I have also added new tests to make sure that replication bytes in/out calculation is done correctly both for cases where all metrics are present as well as when metrics are missing.
显示
- ce-sbk/src/main/java/com/linkedin/kafka/cruisecontrol/monitor/sampling/CruiseControlMetricsProcessor.java 148 个添加, 0 个删除...ntrol/monitor/sampling/CruiseControlMetricsProcessor.java
- ce-sbk/src/main/java/com/linkedin/kafka/cruisecontrol/monitor/sampling/holder/BrokerLoad.java 8 个添加, 1 个删除...fka/cruisecontrol/monitor/sampling/holder/BrokerLoad.java
- ce-sbk/src/test/java/com/linkedin/kafka/cruisecontrol/monitor/sampling/CruiseControlMetricsProcessorTest.java 234 个添加, 17 个删除...l/monitor/sampling/CruiseControlMetricsProcessorTest.java
加载中
想要评论请 注册 或 登录