public class StickyTaskAssignor extends Object implements TaskAssignor
TaskAssignor.AssignmentError, TaskAssignor.TaskAssignment
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_STICKY_NON_OVERLAP_COST |
static int |
DEFAULT_STICKY_TRAFFIC_COST |
Constructor and Description |
---|
StickyTaskAssignor() |
StickyTaskAssignor(boolean mustPreserveActiveTaskAssignment) |
Modifier and Type | Method and Description |
---|---|
TaskAssignor.TaskAssignment |
assign(ApplicationState applicationState) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure, onAssignmentComputed
public static final int DEFAULT_STICKY_TRAFFIC_COST
public static final int DEFAULT_STICKY_NON_OVERLAP_COST
public StickyTaskAssignor()
public StickyTaskAssignor(boolean mustPreserveActiveTaskAssignment)
public TaskAssignor.TaskAssignment assign(ApplicationState applicationState)
assign
in interface TaskAssignor
applicationState
- the metadata for this Kafka Streams application