[
https://issues.apache.org/jira/browse/KAFKA-15278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee updated KAFKA-15278:
-------------------------------
Description:
The necessary Java code that represents the {{ConsumerGroupHeartbeatRequest}}
and {{ConsumerGroupHeartbeatResponse}} are already present in the codebase. It
is assumed that the scaffolding for the other two will come along in time.
* Implement {{ConsumerGroupRequestManager}}
* Ensure that {{DefaultBackgroundThread}} correctly calculates I/O timeouts so
that the heartbeat occurs within the {{group.consumer.session.timeout.ms}}
interval regardless of other {{RequestManager}} instance activity
* Ensure error is handled correctly
* Ensure MembershipStateManager is updated on both successful and failures
cases, and the state machine is transioned to the correct state.
This task is part of the work to implement support for the new KIP-848 consumer
group protocol.
was:
The necessary Java code that represents the {{ConsumerGroupHeartbeatRequest}}
and {{ConsumerGroupHeartbeatResponse}} are already present in the codebase. It
is assumed that the scaffolding for the other two will come along in time.
* Implement {{ConsumerGroupRequestManager}}
* Ensure that {{DefaultBackgroundThread}} correctly calculates I/O timeouts so
that the heartbeat occurs within the {{group.consumer.session.timeout.ms}}
interval regardless of other {{RequestManager}} instance activity
* Ensure error is handled correctly
This task is part of the work to implement support for the new KIP-848 consumer
group protocol.
> Implement client support for KIP-848 ConsumerGroupHeartbeat protocol RPC
> ------------------------------------------------------------------------
>
> Key: KAFKA-15278
> URL: https://issues.apache.org/jira/browse/KAFKA-15278
> Project: Kafka
> Issue Type: Sub-task
> Components: clients, consumer
> Reporter: Kirk True
> Assignee: Philip Nee
> Priority: Major
> Labels: consumer-threading-refactor, kip-848,
> kip-848-client-support, kip-848-e2e, kip-848-preview
>
> The necessary Java code that represents the {{ConsumerGroupHeartbeatRequest}}
> and {{ConsumerGroupHeartbeatResponse}} are already present in the codebase.
> It is assumed that the scaffolding for the other two will come along in time.
> * Implement {{ConsumerGroupRequestManager}}
> * Ensure that {{DefaultBackgroundThread}} correctly calculates I/O timeouts
> so that the heartbeat occurs within the {{group.consumer.session.timeout.ms}}
> interval regardless of other {{RequestManager}} instance activity
> * Ensure error is handled correctly
> * Ensure MembershipStateManager is updated on both successful and failures
> cases, and the state machine is transioned to the correct state.
> 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)
