Map<TaskId, Set<TopicPartition>> partitionGroups(
final Map<Integer, Set<String>> topicGroups,
final Cluster metadata)DefaultPartitionGrouper
DefaultPartitionGrouper is a concrete PartitionGrouper that…FIXME
partitionGroups Method
|
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.
|