segmentio / kafka-go

Kafka library in Go
MIT License
7.61k stars 790 forks source link

Static Membership #493

Open tfishco opened 4 years ago

tfishco commented 4 years ago

Static Membership Since kafka 2.3 it has been possible to use static membership across multiple group generations. Meaning that if a consumer goes down, a rebalance does not occur right away allowing for the crashed instance to pick up the same partitions.

KIP-345

Is this something that this library supports / allows the developer to configure at the consumer level?

achille-roussel commented 4 years ago

Hello @tfishco, thanks for starting the conversation!

kafka-go currently doesn't support the static membership feature that was introduced in kafka 2.3.

If are able to, we would welcome a contribution to add support for this feature.

achille-roussel commented 3 years ago

This work still needs to be done.