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

Class TaskAssignor.TaskAssignment

java.lang.Object

org.apache.kafka.streams.processor.assignment.TaskAssignor.TaskAssignment

Enclosing interface:

TaskAssignor

public static class TaskAssignor.TaskAssignment
extends Object

Wrapper class for the final assignment of active and standbys tasks to individual KafkaStreams clients.

Constructor Summary

Constructors

Constructor	Description
TaskAssignment(Collection<KafkaStreamsAssignment> assignment)

Method Summary

Modifier and Type	Method	Description
Collection<KafkaStreamsAssignment>	assignment()

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TaskAssignment

public TaskAssignment(Collection<KafkaStreamsAssignment> assignment)

Method Details

assignment

public Collection<KafkaStreamsAssignment> assignment()

Returns:

the assignment of tasks to kafka streams clients.