From d93967564105b51e85665b3945f1eb663d914c61 Mon Sep 17 00:00:00 2001 From: Kirk True Date: Mon, 6 Oct 2025 16:49:22 -0700 Subject: [PATCH] Added comment to NetworkClientDelegate.doSend() change --- .../kafka/clients/consumer/internals/NetworkClientDelegate.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java index 772ca911d11..ca0492e39b5 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/NetworkClientDelegate.java @@ -212,6 +212,8 @@ public class NetworkClientDelegate implements AutoCloseable { if (!client.ready(node, currentTimeMs)) { AuthenticationException authenticationException = client.authenticationException(node); + // The client may not be ready because it hit an unrecoverable authentication error. In that case, there's + // no benefit from retrying, so propagate the error here. if (authenticationException != null) { request.callback().onComplete( new ClientResponse(