public static class TaskAssignor.TaskAssignment extends Object
Constructor and Description |
---|
TaskAssignment(Collection<KafkaStreamsAssignment> assignment) |
Modifier and Type | Method and Description |
---|---|
Collection<KafkaStreamsAssignment> |
assignment() |
public TaskAssignment(Collection<KafkaStreamsAssignment> assignment)
public Collection<KafkaStreamsAssignment> assignment()