Kirk True created KAFKA-15284: --------------------------------- Summary: Determine group protocol at client initialization Key: KAFKA-15284 URL: https://issues.apache.org/jira/browse/KAFKA-15284 Project: Kafka Issue Type: Task Components: clients, consumer Reporter: Kirk True Assignee: Kirk True
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. 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)