[
https://issues.apache.org/jira/browse/KAFKA-15284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-15284:
------------------------------
Description:
At client initialization, we need to determine which of the
{{ConsumerDelegate}} implementations to use:
# {{LegacyKafkaConsumerDelegate}}
# {{AsyncKafkaConsumerDelegate}}
There are conditions defined by KIP-848 that determine client eligibility to
use the new protocol. This will be modeled by the {{{}GroupProtocolResolver{}}}.
Known tasks:
* Determine at what point in the {{Consumer}} initialization the network
communication should happen
* Determine what RPCs to invoke in order to determine eligibility (API
versions, IBP version, etc.)
* Implement the network client lifecycle (startup, communication, shutdown,
etc.)
* Determine the fallback path in case the client is not eligible to use the
protocol
was:
At client initialization, we need to determine which of the
{{ConsumerDelegate}} implementations to use:
# {{LegacyKafkaConsumerDelegate}}
# {{AsyncKafkaConsumerDelegate}}
There are conditions defined by KIP-848 that determine client eligibility to
use the new protocol. This will be modeled by the—deep
breath—{{{}ConsumerGroupProtocolVersionResolver{}}}.
Known tasks:
* Determine at what point in the {{Consumer}} initialization the network
communication should happen
* Determine what RPCs to invoke in order to determine eligibility (API
versions, IBP version, etc.)
* Implement the network client lifecycle (startup, communication, shutdown,
etc.)
* Determine the fallback path in case the client is not eligible to use the
protocol
> Implement GroupProtocolResolver to determine consumer group protocol
> --------------------------------------------------------------------
>
> Key: KAFKA-15284
> URL: https://issues.apache.org/jira/browse/KAFKA-15284
> Project: Kafka
> Issue Type: New Feature
> Components: clients, consumer
> Reporter: Kirk True
> Priority: Major
> Labels: kip-848-client-support
> Fix For: 4.0.0
>
>
> At client initialization, we need to determine which of the
> {{ConsumerDelegate}} implementations to use:
> # {{LegacyKafkaConsumerDelegate}}
> # {{AsyncKafkaConsumerDelegate}}
> There are conditions defined by KIP-848 that determine client eligibility to
> use the new protocol. This will be modeled by the
> {{{}GroupProtocolResolver{}}}.
> Known tasks:
> * Determine at what point in the {{Consumer}} initialization the network
> communication should happen
> * Determine what RPCs to invoke in order to determine eligibility (API
> versions, IBP version, etc.)
> * Implement the network client lifecycle (startup, communication, shutdown,
> etc.)
> * Determine the fallback path in case the client is not eligible to use the
> protocol
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
