Open ekeric13 opened 2 years ago
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.
Any plans?
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.