PartitionGrouper Contract

PartitionGrouper is the abstraction of partition groupers that can partitionGroups.

Table 1. PartitionGrouper Contract
Method Description


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

Used exclusively when StreamsPartitionAssignor is requested to assign tasks to consumer clients

DefaultPartitionGrouper is the one and only known implementation of the PartitionGrouper Contract.

results matching ""

    No results matching ""