diff --git a/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java b/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java index d047c79ce8a1c..6eca0d2858165 100644 --- a/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java +++ b/clients/src/main/java/org/apache/kafka/common/network/SslTransportLayer.java @@ -917,7 +917,7 @@ private void handshakeFailure(SSLException sslException, boolean flush) { // unable to process the server message and an SSLException is thrown: // javax.net.ssl.SSLException: Unrecognized SSL message, plaintext connection? // b) If server closes the connection gracefully during handshake, client may receive close_notify - // and and an SSLException is thrown: + // and an SSLException is thrown: // javax.net.ssl.SSLException: Received close_notify during handshake // We want to handle a) as a non-retriable SslAuthenticationException and b) as a retriable IOException. // To do this we need to rely on the exception string. Since it is safer to throw a retriable exception