@FunctionalInterface public static interface TaskAssignmentUtils.MoveStandbyTaskPredicate
Modifier and Type | Method and Description |
---|---|
boolean |
canMoveStandbyTask(KafkaStreamsState source,
KafkaStreamsState destination,
TaskId taskId,
Map<ProcessId,KafkaStreamsAssignment> assignments) |
boolean canMoveStandbyTask(KafkaStreamsState source, KafkaStreamsState destination, TaskId taskId, Map<ProcessId,KafkaStreamsAssignment> assignments)