...
Code Block | ||||
---|---|---|---|---|
| ||||
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(); } |
...