public class DatabalancerUtils extends Object
Constructor and Description |
---|
DatabalancerUtils() |
Modifier and Type | Method and Description |
---|---|
static boolean |
anyUnevenLoadEnabled(kafka.server.KafkaConfig kafkaConfig) |
static Integer |
getBrokerId(kafka.server.KafkaConfig config) |
static List<String> |
getConfiguredLogDirs(kafka.server.KafkaConfig config)
Get the log directories from the Kafka Config.
|
public static Integer getBrokerId(kafka.server.KafkaConfig config)
public static List<String> getConfiguredLogDirs(kafka.server.KafkaConfig config)
public static boolean anyUnevenLoadEnabled(kafka.server.KafkaConfig kafkaConfig)