Skip to content


Creating Instance

PartitionGrouper takes no arguments to be created.

PartitionGrouper is created when:

  • StreamsPartitionAssignor is requested to configure


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


partitionGroups is used when:

  • StreamsPartitionAssignor is requested to assign

Maximum Number of Partitions

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

maxNumPartitions finds the maximum number of partitions across all the given topics (using Cluster metadata).

Back to top