[ https://issues.apache.org/jira/browse/KAFKA-15275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lianet Magrans updated KAFKA-15275: ----------------------------------- Description: Provide the Java client support for the consumer group member state machine, including: * Define the states of the client member, based on the heartbeat {{ConsumerGroupHeartbeat}} data structure & state transitions * Determine the valid transitions between those states * Provide functions to update state on successful and failed HB responses The state machine won't do any error handling, it's just responsible for doing the appropriate state transitions and keeping the member info (id, epoch, assignment) This task is part of the work to implement support for the new KIP-848 consumer group protocol. was: Provide the Java client support for the consumer group member state machine, including: * Define the states of the client member, based on the heartbeat {{ConsumerGroupHeartbeat}} data structure & state transitions * Determine the valid transitions between those states * Implement logic to ensure that the data in the {{ConsumerGroupHeartbeatResponse}} is validated by the state machine, including throwing the correct exception types This task is part of the work to implement support for the new KIP-848 consumer group protocol. > Implement consumer group membership state machine > ------------------------------------------------- > > Key: KAFKA-15275 > URL: https://issues.apache.org/jira/browse/KAFKA-15275 > Project: Kafka > Issue Type: Sub-task > Components: clients, consumer > Reporter: Kirk True > Assignee: Lianet Magrans > Priority: Major > Labels: kip-848, kip-848-client-support > > Provide the Java client support for the consumer group member state machine, > including: > * Define the states of the client member, based on the heartbeat > {{ConsumerGroupHeartbeat}} data structure & state transitions > * Determine the valid transitions between those states > * Provide functions to update state on successful and failed HB responses > The state machine won't do any error handling, it's just responsible for > doing the appropriate state transitions and keeping the member info (id, > epoch, assignment) > This task is part of the work to implement support for the new KIP-848 > consumer group protocol. -- This message was sent by Atlassian Jira (v8.20.10#820010)