|
@@ -16,6 +16,7 @@ import org.springframework.beans.factory.annotation.Value;
|
|
|
import org.springframework.boot.CommandLineRunner;
|
|
|
import org.springframework.core.annotation.Order;
|
|
|
import org.springframework.stereotype.Component;
|
|
|
+import org.springframework.util.ResourceUtils;
|
|
|
|
|
|
import javax.annotation.PostConstruct;
|
|
|
import java.util.Collection;
|
|
@@ -98,10 +99,10 @@ public class CloudKafkaConsumerFromEdgeTopic implements CommandLineRunner {
|
|
|
props.put("ssl.endpoint.identification.algorithm",algorithm);
|
|
|
// properties.put("ssl.truststore.location", ResourceUtils.getFile(truststorelocaltion).getPath());
|
|
|
// properties.put("ssl.truststore.password", keystorepassword);
|
|
|
- props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG,keystorelocaltion);
|
|
|
+ props.put(SslConfigs.SSL_KEYSTORE_LOCATION_CONFIG, ResourceUtils.getFile(keystorelocaltion).getPath());
|
|
|
props.put(SslConfigs.SSL_KEYSTORE_PASSWORD_CONFIG,keystorepassword);
|
|
|
props.put(SslConfigs.SSL_KEY_PASSWORD_CONFIG,keypassword);
|
|
|
- props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG,truststorelocaltion);
|
|
|
+ props.put(SslConfigs.SSL_TRUSTSTORE_LOCATION_CONFIG, ResourceUtils.getFile(truststorelocaltion).getPath());
|
|
|
props.put(SslConfigs.SSL_TRUSTSTORE_PASSWORD_CONFIG,truststorepassword);
|
|
|
|
|
|
|