Fix formatting

This commit is contained in:
Roman Zabaluev 2023-08-02 20:50:10 +08:00
parent c4273e5c94
commit 2030489183
3 changed files with 5 additions and 5 deletions

View file

@ -109,7 +109,7 @@ public class ClustersProperties {
public static class TruststoreConfig { public static class TruststoreConfig {
String truststoreLocation; String truststoreLocation;
String truststorePassword; String truststorePassword;
boolean verifySSL = true; boolean verifySsl = true;
} }
@Data @Data

View file

@ -18,7 +18,7 @@ public final class KafkaClientSslPropertiesUtil {
return; return;
} }
if (!truststoreConfig.isVerifySSL()) { if (!truststoreConfig.isVerifySsl()) {
sink.put(SSL_ENGINE_FACTORY_CLASS_CONFIG, InsecureSslEngineFactory.class); sink.put(SSL_ENGINE_FACTORY_CLASS_CONFIG, InsecureSslEngineFactory.class);
return; return;
} }

View file

@ -46,8 +46,8 @@ public class WebClientConfigurator {
public WebClientConfigurator configureSsl(@Nullable ClustersProperties.TruststoreConfig truststoreConfig, public WebClientConfigurator configureSsl(@Nullable ClustersProperties.TruststoreConfig truststoreConfig,
@Nullable ClustersProperties.KeystoreConfig keystoreConfig) { @Nullable ClustersProperties.KeystoreConfig keystoreConfig) {
if (truststoreConfig != null && !truststoreConfig.isVerifySSL()) { if (truststoreConfig != null && !truststoreConfig.isVerifySsl()) {
return configureNoSSL(); return configureNoSsl();
} }
return configureSsl( return configureSsl(
@ -103,7 +103,7 @@ public class WebClientConfigurator {
} }
@SneakyThrows @SneakyThrows
public WebClientConfigurator configureNoSSL() { public WebClientConfigurator configureNoSsl() {
var contextBuilder = SslContextBuilder.forClient(); var contextBuilder = SslContextBuilder.forClient();
contextBuilder.trustManager(InsecureTrustManagerFactory.INSTANCE); contextBuilder.trustManager(InsecureTrustManagerFactory.INSTANCE);