Kirk True created KAFKA-15556: --------------------------------- Summary: Remove isUnavailable and maybeThrowAuthFailure if possible Key: KAFKA-15556 URL: https://issues.apache.org/jira/browse/KAFKA-15556 Project: Kafka Issue Type: Sub-task Reporter: Kirk True
The "new consumer" (i.e. {{{}PrototypeAsyncConsumer{}}}) was designed to handle networking details in a more centralized way. However, in order to reuse code between the existing {{KafkaConsumer}} and the new {{{}PrototypeAsyncConsumer{}}}, that design goal was "relaxed" when the {{NetworkClientDelegate}} capitulated and -stole- copied three methods from {{ConsumerNetworkClient}} related to detecting node status: # {{isUnavailable}} # {{maybeThrowAuthFailure}} # {{tryConnect}} Unfortunately, these have found their way into the {{FetchRequestManager}} and {{OffsetsRequestManager}} implementations. We should review if we can clean up—or even remove—this leaky abstraction. -- This message was sent by Atlassian Jira (v8.20.10#820010)