Support for KIP-429: Cooperative rebalancing

[ekeric13]

It would be great to use this feature: https://cwiki.apache.org/confluence/display/KAFKA/KIP-429%3A+Kafka+Consumer+Incremental+Rebalance+Protocol

I believe it is supported in other clients: https://pkg.go.dev/github.com/Shopify/sarama#StickyBalanceStrategyName https://pkg.go.dev/github.com/twmb/franz-go/pkg/kgo#CooperativeStickyBalancer

But I couldn't find it in this one.

[sejin-P]

Any plans?

[justinrixx]

FWIW, I don't think Sarama supports this. That StickyBalanceStrategyName is an assignor strategy, not a balancing algorithm.

There's also an open issue in the Sarama project: https://github.com/IBM/sarama/issues/1858