KAFKALESS-1167: Configuration of incremental balancing (#6918)
* KAFKALESS-1167: Configuration of incremental balancing * Use Double.compare * Use constants from BalancerConfigs * Add Incremental balancing default value as a constant * Add config validations * Factor out code for dynamic config * Better documentation, removed default values from doc * Update clients/src/main/java/org/apache/kafka/common/config/internals/BalancerConfigs.java Co-authored-by:Stanislav Kozlovski <stanislav_kozlovski@outlook.com> Co-authored-by:
Stanislav Kozlovski <stanislav_kozlovski@outlook.com>
显示
- ce-sbk/src/main/java/com/linkedin/kafka/cruisecontrol/config/KafkaCruiseControlConfig.java 48 个添加, 0 个删除.../kafka/cruisecontrol/config/KafkaCruiseControlConfig.java
- ce-sbk/src/main/java/io/confluent/databalancer/event/SbcConfigUpdateEvent.java 1 个添加, 1 个删除...io/confluent/databalancer/event/SbcConfigUpdateEvent.java
- clients/src/main/java/org/apache/kafka/common/config/internals/BalancerConfigs.java 64 个添加, 1 个删除...apache/kafka/common/config/internals/BalancerConfigs.java
- core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala 4 个添加, 0 个删除core/src/test/scala/unit/kafka/server/KafkaConfigTest.scala
加载中
想要评论请 注册 或 登录