TaskAssignor.TaskAssignment (streams 8.1.1-ce API)

java.lang.Object

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

Enclosing interface:: TaskAssignor

public static class TaskAssignor.TaskAssignmentextends 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.