Class AssignmentConfigs

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