diff --git a/src/main/java/com/example/demokafka/util/KafkaUtil.java b/src/main/java/com/example/demokafka/util/KafkaUtil.java index 88e4445..977c637 100644 --- a/src/main/java/com/example/demokafka/util/KafkaUtil.java +++ b/src/main/java/com/example/demokafka/util/KafkaUtil.java @@ -38,10 +38,11 @@ public class KafkaUtil { properties.setProperty("ssl.endpoint.identification.algorithm", ""); return properties; } + //keytool -keystore D:/keystore/client.trustestore.p12 -storepass fEVcb^QFB;IN$K5 -noprompt -alias client.trustestore -import -file D:/keystore/ca.crt -storetype PKCS12 + //keytool -keystore D:/keystore/client.trustestore.p12 -storepass pwd123 -noprompt -alias client.trustestore -import -file D:/keystore/ca.crt -storetype PKCS12 public Properties getSafeConsumerPro() { Properties properties = new Properties(); - properties.setProperty("group.id", "isv-kafka"); properties.setProperty("key.deserializer", StringDeserializer.class.getName()); properties.setProperty("value.deserializer", StringDeserializer.class.getName()); @@ -51,7 +52,7 @@ public class KafkaUtil { properties.setProperty("sasl.mechanism", "SCRAM-SHA-512"); properties.setProperty("security.protocol", "SASL_SSL"); properties.setProperty("ssl.truststore.location", trustestore); - properties.setProperty("ssl.truststore.password", secret); + properties.setProperty("ssl.truststore.password", "pwd123"); }else{ properties.setProperty("bootstrap.servers", "10.0.10.153:29551,10.0.10.153:29552"); }