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 |
---|---|
java.util.Map<TaskId,java.util.Set<TopicPartition>> |
partitionGroups(java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> topicGroups,
Cluster metadata)
Returns a map of task ids to groups of partitions.
|
java.util.Map<TaskId,java.util.Set<TopicPartition>> partitionGroups(java.util.Map<java.lang.Integer,java.util.Set<java.lang.String>> topicGroups, Cluster metadata)
DefaultPartitionGrouper
for more information.topicGroups
- The map from the TopologyBuilder.topicGroups()
topic group} id to topicsmetadata
- Metadata of the consuming cluster