abbccdda commented on a change in pull request #10156:
URL: https://github.com/apache/kafka/pull/10156#discussion_r584950105
##########
File path:
clients/src/main/java/org/apache/kafka/common/security/ssl/DefaultSslEngineFactory.java
##########
@@ -211,15 +390,15 @@ private SSLEngine createSslEngine(Mode mode, String
peerHost, int peerPort, Stri
}
return sslEngine;
}
+
private static SslClientAuth createSslClientAuth(String key) {
SslClientAuth auth = SslClientAuth.forConfig(key);
if (auth != null) {
return auth;
}
log.warn("Unrecognized client authentication configuration {}.
Falling " +
"back to NONE. Recognized client authentication
configurations are {}.",
- key, String.join(", ", SslClientAuth.VALUES.stream().
- map(Enum::name).collect(Collectors.toList())));
+ key,
SslClientAuth.VALUES.stream().map(Enum::name).collect(Collectors.joining(",
")));
Review comment:
side cleaning
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
