Kafka cooperative rebalance

[caiquefigueiredo]

Hey, there! Is there some way to use cooperative assignment strategy?
I've tried changing the configuration partition.assignment.strategy to cooperative-sticky (related librdkafka docs) but got the following error:

Group "group": application *assign() call failed: Changes to the current assignment must be made using incremental_assign() or incremental_unassign() when rebalance protocol type is COOPERATIVE

[AlexeyRaga]

Hi, I am not aware of such a protocol and have not tried to use this strategy myself.
Perhaps deserves an investigation.

[RahulXTmCoding]

@caiquefigueiredo @AlexeyRaga
I have raised a pr for the support of cooperative rebalance

#198

This should fix the problem you are facing. I had the similar usecase.