THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
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.
...