mirror of https://github.com/apache/kafka.git
Added comment to NetworkClientDelegate.doSend() change
This commit is contained in:
parent
b04b0a2c73
commit
d939675641
|
@ -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(
|
||||
|
|
Loading…
Reference in New Issue