public class DatabalancerUtils extends Object
Constructor and Description |
---|
DatabalancerUtils() |
Modifier and Type | Method and Description |
---|---|
static boolean |
anyUnevenLoadEnabled(kafka.server.KafkaConfig kafkaConfig) |
static boolean |
anyUnevenLoadEnabled(String autoHealMode) |
static kafka.common.AliveBrokersMetadata |
buildAliveBrokerMetadata(org.apache.kafka.image.ClusterImage clusterImage,
org.apache.kafka.image.BrokerReplicaExclusionsImage exclusionsImage)
Return an AliveBrokerSnapshot based on the supplied metadata images.
|
static String |
generateCcTopicExclusionRegex(kafka.server.KafkaConfig config) |
static String |
generateCcTopicExclusionRegex(List<String> topicNames,
List<String> topicPrefixes)
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.
|
static long |
taskHistoryRetentionMs(kafka.server.KafkaConfig config) |
public static Integer getBrokerId(kafka.server.KafkaConfig config)
public static long taskHistoryRetentionMs(kafka.server.KafkaConfig config)
public static List<String> getConfiguredLogDirs(kafka.server.KafkaConfig config)
public static boolean anyUnevenLoadEnabled(kafka.server.KafkaConfig kafkaConfig)
public static boolean anyUnevenLoadEnabled(String autoHealMode)
public static String generateCcTopicExclusionRegex(kafka.server.KafkaConfig config)
public static String generateCcTopicExclusionRegex(List<String> topicNames, List<String> topicPrefixes)
public static kafka.common.AliveBrokersMetadata buildAliveBrokerMetadata(org.apache.kafka.image.ClusterImage clusterImage, org.apache.kafka.image.BrokerReplicaExclusionsImage exclusionsImage)
clusterImage
- The cluster image upon which to base the AliveBrokerSnapshotexclusionsImage
- The exclusions image containing information as to which broker is excluded in the cluster