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 ""