org.apache.kafka.streams.processor.assignment.assignors.StickyTaskAssignor

All Implemented Interfaces:: org.apache.kafka.common.Configurable, TaskAssignor

public class StickyTaskAssignorextends Object implements TaskAssignor

Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.kafka.streams.processor.assignment.TaskAssignor
TaskAssignor.AssignmentError, TaskAssignor.TaskAssignment
Field Summary
Fields
Modifier and Type
Field
Description
static final int
DEFAULT_STICKY_NON_OVERLAP_COST

static final int
DEFAULT_STICKY_TRAFFIC_COST
Constructor Summary
Constructors
Constructor
Description
StickyTaskAssignor()

StickyTaskAssignor(boolean mustPreserveActiveTaskAssignment)
Method Summary
Modifier and Type
Method
Description
TaskAssignor.TaskAssignment
assign(ApplicationState applicationState)

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:
  Constant Field Values
- DEFAULT_STICKY_NON_OVERLAP_COST
  public static final int DEFAULT_STICKY_NON_OVERLAP_COST
  See Also:
  Constant Field Values
Constructor Details
- StickyTaskAssignor
  public StickyTaskAssignor()
- StickyTaskAssignor
  public StickyTaskAssignor(boolean mustPreserveActiveTaskAssignment)
Method Details
- assign
  public TaskAssignor.TaskAssignment assign(ApplicationState applicationState)
  Specified by:
  assign in interface TaskAssignor
  Parameters:
  applicationState - the metadata for this Kafka Streams application
  Returns:
  the assignment of active and standby tasks to KafkaStreams clients

Class StickyTaskAssignor

Nested Class Summary