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

Class StickyTaskAssignor

java.lang.Object

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

All Implemented Interfaces:

Configurable, TaskAssignor

public class StickyTaskAssignor
extends 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