PartitionGrouper Contract

PartitionGrouper is the abstraction of partition groupers that can partitionGroups.

Table 1. PartitionGrouper Contract
Method Description

partitionGroups

 
Map<TaskId, Set<TopicPartition>> partitionGroups(
  Map<Integer, Set<String>> topicGroups, Cluster metadata)

Used exclusively when StreamsPartitionAssignor is requested to assign tasks to consumer clients
Note
 DefaultPartitionGrouper is the one and only known implementation of the PartitionGrouper Contract.

results matching ""

    No results matching ""