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 void |
ensureConstraintsAreMet(GoalConstraints goalConstraints,
ClusterModel clusterModel,
Set<String> excludedTopics) |
static Optional<Cell> |
expectedCellForTenant(ClusterModel clusterModel,
String tenantId)
Returns cell a tenant partitions are supposed to be in.
|
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 String |
getTenantId(Replica replica) |
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 clusterpublic static void ensureConstraintsAreMet(GoalConstraints goalConstraints, ClusterModel clusterModel, Set<String> excludedTopics) throws OptimizationFailureException
OptimizationFailureException
public static Optional<Cell> expectedCellForTenant(ClusterModel clusterModel, String tenantId)