public class CellLoadRefresher extends Object
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_REFRESH_INTERVAL_MS |
Constructor and Description |
---|
CellLoadRefresher(BiConsumer<Set<org.apache.kafka.common.CellLoad>,Long> cellLoadConsumer,
ClusterBalanceManager balanceManager,
org.apache.kafka.common.utils.Time time,
kafka.server.KafkaConfig config,
org.apache.kafka.server.util.Scheduler scheduler,
org.apache.kafka.controller.metrics.CellMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.server.util.Scheduler |
createDefaultScheduler() |
void |
start() |
public CellLoadRefresher(BiConsumer<Set<org.apache.kafka.common.CellLoad>,Long> cellLoadConsumer, ClusterBalanceManager balanceManager, org.apache.kafka.common.utils.Time time, kafka.server.KafkaConfig config, org.apache.kafka.server.util.Scheduler scheduler, org.apache.kafka.controller.metrics.CellMetrics metrics)