Class StickyTaskAssignor
java.lang.Object
org.apache.kafka.streams.processor.assignment.assignors.StickyTaskAssignor
- All Implemented Interfaces:
Configurable
,TaskAssignor
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.kafka.streams.processor.assignment.TaskAssignor
TaskAssignor.AssignmentError, TaskAssignor.TaskAssignment
-
Field Summary
Modifier and TypeFieldDescriptionstatic final int
static final int
-
Constructor Summary
-
Method Summary
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.kafka.streams.processor.assignment.TaskAssignor
configure, onAssignmentComputed
-
Field Details
-
DEFAULT_STICKY_TRAFFIC_COST
public static final int DEFAULT_STICKY_TRAFFIC_COST- See Also:
-
DEFAULT_STICKY_NON_OVERLAP_COST
public static final int DEFAULT_STICKY_NON_OVERLAP_COST- See Also:
-
-
Constructor Details
-
StickyTaskAssignor
public StickyTaskAssignor() -
StickyTaskAssignor
public StickyTaskAssignor(boolean mustPreserveActiveTaskAssignment)
-
-
Method Details
-
assign
- Specified by:
assign
in interfaceTaskAssignor
- Parameters:
applicationState
- the metadata for this Kafka Streams application- Returns:
- the assignment of active and standby tasks to KafkaStreams clients
-