Package org.apache.kafka.streams.processor.assignment

Class AssignmentConfigs

java.lang.Object

org.apache.kafka.streams.processor.assignment.AssignmentConfigs

public class AssignmentConfigs
extends Object

Assignment related configs for the Kafka Streams TaskAssignor.

Constructor Summary

Constructors

Constructor	Description
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)
AssignmentConfigs(Long acceptableRecoveryLag, Integer maxWarmupReplicas, Integer numStandbyReplicas, Long probingRebalanceIntervalMs, List<String> rackAwareAssignmentTags)

Method Summary

Modifier and Type	Method	Description
long	acceptableRecoveryLag()	The configured acceptable recovery lag according to StreamsConfig.ACCEPTABLE_RECOVERY_LAG_CONFIG
int	maxWarmupReplicas()	The maximum warmup replicas as configured via StreamsConfig.MAX_WARMUP_REPLICAS_CONFIG
int	numStandbyReplicas()	The number of standby replicas as configured via StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG
static AssignmentConfigs	of(StreamsConfig configs)
long	probingRebalanceIntervalMs()	The probing rebalance interval in milliseconds as configured via StreamsConfig.PROBING_REBALANCE_INTERVAL_MS_CONFIG
String	rackAwareAssignmentStrategy()	The rack-aware assignment strategy as configured via StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_CONFIG
List<String>	rackAwareAssignmentTags()	The rack-aware assignment tags as configured via StreamsConfig.RACK_AWARE_ASSIGNMENT_TAGS_CONFIG
OptionalInt	rackAwareNonOverlapCost()	The rack-aware assignment non-overlap cost as configured via StreamsConfig.RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_CONFIG
OptionalInt	rackAwareTrafficCost()	The rack-aware assignment traffic cost as configured via StreamsConfig.RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_CONFIG
String	toString()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

AssignmentConfigs

public AssignmentConfigs(long acceptableRecoveryLag,
 int maxWarmupReplicas,
 int numStandbyReplicas,
 long probingRebalanceIntervalMs,
 List<String> rackAwareAssignmentTags,
 OptionalInt rackAwareTrafficCost,
 OptionalInt rackAwareNonOverlapCost,
 String rackAwareAssignmentStrategy)

AssignmentConfigs

public AssignmentConfigs(long acceptableRecoveryLag,
 int maxWarmupReplicas,
 int numStandbyReplicas,
 long probingRebalanceIntervalMs,
 List<String> rackAwareAssignmentTags,
 int rackAwareTrafficCost,
 int rackAwareNonOverlapCost,
 String rackAwareAssignmentStrategy)

AssignmentConfigs

public AssignmentConfigs(Long acceptableRecoveryLag,
 Integer maxWarmupReplicas,
 Integer numStandbyReplicas,
 Long probingRebalanceIntervalMs,
 List<String> rackAwareAssignmentTags)

Method Details

of

public static AssignmentConfigs of(StreamsConfig configs)

acceptableRecoveryLag

public long acceptableRecoveryLag()

The configured acceptable recovery lag according to StreamsConfig.ACCEPTABLE_RECOVERY_LAG_CONFIG

maxWarmupReplicas

public int maxWarmupReplicas()

The maximum warmup replicas as configured via StreamsConfig.MAX_WARMUP_REPLICAS_CONFIG

numStandbyReplicas

public int numStandbyReplicas()

The number of standby replicas as configured via StreamsConfig.NUM_STANDBY_REPLICAS_CONFIG

probingRebalanceIntervalMs

public long probingRebalanceIntervalMs()

The probing rebalance interval in milliseconds as configured via StreamsConfig.PROBING_REBALANCE_INTERVAL_MS_CONFIG

rackAwareAssignmentTags

public List<String> rackAwareAssignmentTags()

The rack-aware assignment tags as configured via StreamsConfig.RACK_AWARE_ASSIGNMENT_TAGS_CONFIG

rackAwareTrafficCost

public OptionalInt rackAwareTrafficCost()

The rack-aware assignment traffic cost as configured via StreamsConfig.RACK_AWARE_ASSIGNMENT_TRAFFIC_COST_CONFIG

rackAwareNonOverlapCost

public OptionalInt rackAwareNonOverlapCost()

The rack-aware assignment non-overlap cost as configured via StreamsConfig.RACK_AWARE_ASSIGNMENT_NON_OVERLAP_COST_CONFIG

rackAwareAssignmentStrategy

public String rackAwareAssignmentStrategy()

The rack-aware assignment strategy as configured via StreamsConfig.RACK_AWARE_ASSIGNMENT_STRATEGY_CONFIG

toString

public String toString()

Overrides:

toString in class Object