[
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)
