public class DatabalancerUtils extends Object
Constructor and Description |
---|
DatabalancerUtils() |
Modifier and Type | Method and Description |
---|---|
static boolean |
anyUnevenLoadEnabled(kafka.server.KafkaConfig kafkaConfig) |
static String |
generateCcTopicExclusionRegex(kafka.server.KafkaConfig config)
The function forms a regex expression by performing OR operation on the topic names and topic prefixes
considering each of these as string literals.
|
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)
public static String generateCcTopicExclusionRegex(kafka.server.KafkaConfig config)