Skip to content

Conversation

@dpkp
Copy link
Owner

@dpkp dpkp commented May 16, 2025

Implements static consumer group membership from KIP-345. Pass group_instance_id to KafkaConsumer() to specify static group membership. Raises FencedInstanceIdError on duplicate consumers if id is reused (in practice the older consumer is typically the one that raises the error). Partition assignors have been updated to consider static members, aligning with the java client implementations.

Note that there are some internal / non-public interface changes that may break code if it has tight dependencies.

@dpkp dpkp force-pushed the dpkp/kip-345-static-group-membership branch from ee0b9df to da7c856 Compare June 19, 2025 16:22
@dpkp dpkp linked an issue Jun 19, 2025 that may be closed by this pull request
@dpkp dpkp force-pushed the dpkp/kip-345-static-group-membership branch from 9bb49ae to 454ad18 Compare June 23, 2025 22:12
@dpkp dpkp force-pushed the dpkp/kip-345-static-group-membership branch from 2b3cdc0 to e238f66 Compare June 23, 2025 23:01
@dpkp dpkp merged commit 8d75d9a into master Jun 23, 2025
33 of 34 checks passed
@dpkp dpkp deleted the dpkp/kip-345-static-group-membership branch June 23, 2025 23:13
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

Support KIP-345 / Static Consumer Group Membership

2 participants