|
|
|
@ -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");
|
|
|
|
|
}
|
|
|
|
|