kafka-go icon indicating copy to clipboard operation
kafka-go copied to clipboard

Published 20 hours ago • verified publisher icon segmentio

Implement static membership support

Open huszkacs opened this issue 3 years ago • 3 comments

Static membership requires setting of group.instance.id, which requires JoinGroup API key version 5 and Heartbeat API Key version 3. Documentation

Validation of new member.id is changed in later releases. When a client tries to join to a consumer group for the first time with empty memberID, server will return with an error called MEMBER_ID_REQUIRED and a generated memberID for the client. That newly generated memberID needs to be passed to connection retry. Learn more here

Pull request

huszkacs avatar Jun 29 '22 09:06 huszkacs

Hello @huszkacs

I noticed you closed the pull request that you had opened in relation to this issue. Do you have an update to share on the topic?

achille-roussel avatar Sep 16 '22 16:09 achille-roussel

Hello @achille-roussel!

Yes, I did close that issue, because a major refactor had been merged in and my previous implementation of static membership became outdated. I am working on a new implementation using the new structure. I hope I can get it done next week.

huszkacs avatar Sep 16 '22 21:09 huszkacs

@achille-roussel I added a small change, you can find it in the referenced pull request.

huszkacs avatar Sep 19 '22 14:09 huszkacs