DefaultPartitionGrouper
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 | 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 topic group id to topicsmetadata
- Metadata of the consuming cluster