When a new Kafka consumer joins/leaves a consumer group, Kafka runtime triggers a rebalancing process so that a new assignment/mapping of partitions to the new set of consumers is performed. I kindly have three questions on the rebalancing process:
(1) Is it possible to plug in somehow a custom rebalancing algorithm, other than the ones already implemented? (2) Is it possible to pass an external variable to the custom algorithm? (3) Is it possible to dynamically and selectively launch a rebalancing process, other than the known cases (such as when consumer leaves, join etc..)
