|
@@ -106,14 +106,14 @@ public class CloudKafkaConsumerFromEdgeTopic implements CommandLineRunner {
|
|
|
if ("dev".equals(active)){
|
|
|
|
|
|
}else{
|
|
|
-// props.put("security.protocol", securtyprotocol);
|
|
|
-// props.put("ssl.endpoint.identification.algorithm",algorithm);
|
|
|
-// props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, new File(keystorelocaltion).getAbsolutePath());
|
|
|
-// props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, new File(truststorelocaltion).getAbsolutePath());
|
|
|
-// props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG,keystorepassword);
|
|
|
-// props.put(SslConfigs.SSL_KEY_PASSWORD_CONFIG,keypassword);
|
|
|
-//
|
|
|
-// props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG,truststorepassword);
|
|
|
+ props.put("security.protocol", securtyprotocol);
|
|
|
+ props.put("ssl.endpoint.identification.algorithm",algorithm);
|
|
|
+ props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, new File(keystorelocaltion).getAbsolutePath());
|
|
|
+ props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, new File(truststorelocaltion).getAbsolutePath());
|
|
|
+ props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG,keystorepassword);
|
|
|
+ props.put(SslConfigs.SSL_KEY_PASSWORD_CONFIG,keypassword);
|
|
|
+
|
|
|
+ props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG,truststorepassword);
|
|
|
}
|
|
|
|
|
|
|