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 ac16c21bfc8..0175139fea3 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 @@ public final class DefaultSslEngineFactory implements SslEngineFactory { case NONE: break; } - sslEngine.setUseClientMode(false); } else { sslEngine.setUseClientMode(true); SSLParameters sslParams = sslEngine.getSSLParameters();