Hi all, In light of some recent and upcoming rebalancing and availability improvements, it seems we have a need for explicitly triggering a consumer group rebalance. Therefore I'd like to propose adding a new rejoinGroup()method to the Consumer client (better method name suggestions are very welcome).
Please take a look at the KIP and let me know what you think! KIP document: https://cwiki.apache.org/confluence/display/KAFKA/KIP-568%3A+Explicit+rebalance+triggering+on+the+Consumer JIRA: https://issues.apache.org/jira/browse/KAFKA-9525 Cheers, Sophie
