Skip to content
代码片段 群组 项目
派生自 oss-mirrors / ICV / kafka
Loading
用户头像
Vikas Singh 编辑于
* 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.
9317be02
历史
名称 最后提交 最后更新