Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
titleKeyRangeBasedAssignor
inputTopicPartitions := Set<TopicPartition>
brokerAllowIC := Boolean
Subscriptions := Map<String, Subscription>

NumberOfPartitions := size of inputTopicPartitions


This step unblocks the potential to allow a dynamic consumer group scaling beyond partition level capping.

...