|
@@ -16,11 +16,6 @@ public final class KafkaClientSslPropertiesUtil {
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
|
|
|
|
- if (!truststoreConfig.isVerifySsl()) {
|
|
|
|
- sink.put(SslConfigs.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG, "");
|
|
|
|
- return;
|
|
|
|
- }
|
|
|
|
-
|
|
|
|
if (truststoreConfig.getTruststoreLocation() == null) {
|
|
if (truststoreConfig.getTruststoreLocation() == null) {
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
@@ -30,6 +25,10 @@ public final class KafkaClientSslPropertiesUtil {
|
|
if (truststoreConfig.getTruststorePassword() != null) {
|
|
if (truststoreConfig.getTruststorePassword() != null) {
|
|
sink.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, truststoreConfig.getTruststorePassword());
|
|
sink.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG, truststoreConfig.getTruststorePassword());
|
|
}
|
|
}
|
|
|
|
+
|
|
|
|
+ if (!truststoreConfig.isVerifySsl()) {
|
|
|
|
+ sink.put(SslConfigs.SSL_ENDPOINT_IDENTIFICATION_ALGORITHM_CONFIG, "");
|
|
|
|
+ }
|
|
}
|
|
}
|
|
|
|
|
|
}
|
|
}
|