Static Membership

[tambodotdev]

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]

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]

This work still needs to be done.