Page History

package org.apache.kafka.streams.processor.assignment;

public class AssignmentConfigs {
    public long acceptableRecoveryLag();
    public int maxWarmupReplicas();
    public int numStandbyReplicas();
    public long probingRebalanceIntervalMs();
    public List<String> rackAwareAssignmentTags();
    public Optional<Integer>OptionalInt trafficCost();
    public Optional<Integer>OptionalInt nonOverlapCost();
    public String rackAwareAssignmentStrategy();
 }