vamossagar12 opened a new pull request, #14432: URL: https://github.com/apache/kafka/pull/14432
This is the first PR which aims at adding static membership to the new consumer group protocol. If focusses on not triggering a rebalance when a static member sends a ConsumerGroupHeartbeat message with an epoch indicating that it wants to leave the group. One important point to note is that in the KIP , when talking about [static membership](https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol#KIP848:TheNextGenerationoftheConsumerRebalanceProtocol-StaticMembership(KIP-345)), it is mentioned that a static member wants to leave the group, it needs to send a member epoch value equal to -2. I think that might not be needed as the Group Coordinator is able to figure out if the departing member is a static one or not. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
