public class AssignmentConfigs extends Object
TaskAssignor
.Constructor and Description |
---|
AssignmentConfigs(Long acceptableRecoveryLag,
Integer maxWarmupReplicas,
Integer numStandbyReplicas,
Long probingRebalanceIntervalMs,
List<String> rackAwareAssignmentTags) |
AssignmentConfigs(long acceptableRecoveryLag,
int maxWarmupReplicas,
int numStandbyReplicas,
long probingRebalanceIntervalMs,
List<String> rackAwareAssignmentTags,
int rackAwareTrafficCost,
int rackAwareNonOverlapCost,
String rackAwareAssignmentStrategy) |
AssignmentConfigs(long acceptableRecoveryLag,
int maxWarmupReplicas,
int numStandbyReplicas,
long probingRebalanceIntervalMs,
List<String> rackAwareAssignmentTags,
OptionalInt rackAwareTrafficCost,
OptionalInt rackAwareNonOverlapCost,
String rackAwareAssignmentStrategy) |
public AssignmentConfigs(long acceptableRecoveryLag, int maxWarmupReplicas, int numStandbyReplicas, long probingRebalanceIntervalMs, List<String> rackAwareAssignmentTags, OptionalInt rackAwareTrafficCost, OptionalInt rackAwareNonOverlapCost, String rackAwareAssignmentStrategy)
public AssignmentConfigs(long acceptableRecoveryLag, int maxWarmupReplicas, int numStandbyReplicas, long probingRebalanceIntervalMs, List<String> rackAwareAssignmentTags, int rackAwareTrafficCost, int rackAwareNonOverlapCost, String rackAwareAssignmentStrategy)
public static AssignmentConfigs of(StreamsConfig configs)
public long acceptableRecoveryLag()
StreamsConfig.ACCEPTABLE_RECOVERY_LAG_CONFIG
public int maxWarmupReplicas()
StreamsConfig.MAX_WARMUP_REPLICAS_CONFIG
public int numStandbyReplicas()
StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG
public long probingRebalanceIntervalMs()
StreamsConfig.PROBING_REBALANCE_INTERVAL_MS_CONFIG
public List<String> rackAwareAssignmentTags()
StreamsConfig.RACK_AWARE_ASSIGNMENT_TAGS_CONFIG
public OptionalInt rackAwareTrafficCost()
StreamsConfig.RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_CONFIG
public OptionalInt rackAwareNonOverlapCost()
StreamsConfig.RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_CONFIG
public String rackAwareAssignmentStrategy()
StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_CONFIG