@Immutable public final class GoalOptimizationHistoryOptions extends Object
OptimizationOptions
to enable goal optimization history tracking and suspension-aware balancing. Currently,
both hard goals and soft goals will record topic partition movements but only soft goals will consider the suspension
when generating moves.AbstractGoal
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
int |
hashCode() |
long |
historyEpoch()
Epoch of the goal optimization history tracking.
|
static GoalOptimizationHistoryOptions |
of(long historyEpoch,
long topicPartitionMovementExpirationMs,
Set<org.apache.kafka.common.TopicPartition> suspendedTopicPartitions) |
Set<org.apache.kafka.common.TopicPartition> |
suspendedTopicPartitions()
TopicPartition s in this set are suspended from balancing operations, mainly used for fencing off those
partitions with a high number of repeated movements. |
long |
topicPartitionMovementExpirationMs()
Expiration time of each generated topic partition movement.
|
String |
toString() |
public static GoalOptimizationHistoryOptions of(long historyEpoch, long topicPartitionMovementExpirationMs, Set<org.apache.kafka.common.TopicPartition> suspendedTopicPartitions)
public long historyEpoch()
TopicPartitionHistory.epoch()
public long topicPartitionMovementExpirationMs()
public Set<org.apache.kafka.common.TopicPartition> suspendedTopicPartitions()
TopicPartition
s in this set are suspended from balancing operations, mainly used for fencing off those
partitions with a high number of repeated movements.GoalOptimizationHistory