diff --git a/clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java b/clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java index ac16c21bfc836..0175139fea3cc 100644 --- a/clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java +++ b/clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java @@ -200,7 +200,6 @@ private SSLEngine createSslEngine(Mode mode, String peerHost, int peerPort, Stri case NONE: break; } - sslEngine.setUseClientMode(false); } else { sslEngine.setUseClientMode(true); SSLParameters sslParams = sslEngine.getSSLParameters();