获取文件夹内容时发生错误.
派生自
oss-mirrors / ICV / kafka
源项目有可见性限制。
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.
名称 | 最后提交 | 最后更新 |
---|