public interface PartitionGrouper
TaskId
;
the created task ids will then be assigned to Kafka Streams instances that host the stream
processing application.Modifier and Type | Method and Description |
---|---|
Map<TaskId,Set<TopicPartition>> |
partitionGroups(Map<Integer,Set<String>> topicGroups,
Cluster metadata)
Returns a map of task ids to groups of partitions.
|
Map<TaskId,Set<TopicPartition>> partitionGroups(Map<Integer,Set<String>> topicGroups, Cluster metadata)
DefaultPartitionGrouper
for more information.topicGroups
- The map from the topic group id to topicsmetadata
- Metadata of the consuming cluster