kafka-streams-DefaultPartitionGrouper.adoc

DefaultPartitionGrouper

DefaultPartitionGrouper is a concrete PartitionGrouper that…​FIXME

partitionGroups Method

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

Note	partitionGroups is part of the PartitionGrouper Contract to…​FIXME.

partitionGroups…​FIXME

Finding Maximum Number Of Partitions For Topics — maxNumPartitions Method

int maxNumPartitions(
  final Cluster metadata,
  final Set<String> topics)

maxNumPartitions…​FIXME

Note	maxNumPartitions is used exclusively when DefaultPartitionGrouper is requested to partitionGroups.