zhouwentao
/
demo-kafka
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

updates

Browse Source
main
周文涛 2 years ago
parent aa44819945
commit a8dfb75e66
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File

7
src/main/java/com/example/demokafka/util/KafkaUtil.java
Unescape View File

@ -28,7 +28,8 @@ public class KafkaUtil {
properties.setProperty("acks", "all"); properties.setProperty("acks", "all");
properties.setProperty("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); properties.setProperty("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
properties.setProperty("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); properties.setProperty("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
properties.setProperty("sasl.jaas.config", "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"e92224\" password=\"323236g6#\";"); //properties.setProperty("sasl.jaas.config", String.format("org.apache.kafka.common.security.scram.ScramLoginModule required username=\"%s\" password=\"%s\";",appCode,secret));
//properties.setProperty("sasl.jaas.config", "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"e92224\" password=\"323236g6#\";");
properties.setProperty("sasl.mechanism", "SCRAM-SHA-512"); properties.setProperty("sasl.mechanism", "SCRAM-SHA-512");
properties.setProperty("security.protocol", "SASL_SSL"); properties.setProperty("security.protocol", "SASL_SSL");
properties.setProperty("ssl.truststore.location", trustestore); properties.setProperty("ssl.truststore.location", trustestore);
@ -48,10 +49,10 @@ public class KafkaUtil {
properties.setProperty("value.deserializer", StringDeserializer.class.getName()); properties.setProperty("value.deserializer", StringDeserializer.class.getName());
if (StringUtils.isNotBlank(appCode)) { if (StringUtils.isNotBlank(appCode)) {
properties.setProperty("bootstrap.servers", "10.0.10.153:29553,10.0.10.153:29554"); properties.setProperty("bootstrap.servers", "10.0.10.153:29553,10.0.10.153:29554");
properties.setProperty("sasl.jaas.config", String.format("org.apache.kafka.common.security.scram.ScramLoginModule required username=\"%s\" password=\"%s\";",appCode,secret)); properties.setProperty("sasl.jaas.config", "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"dwVendor\" password=\"fEVcb^QFB;IN$K5\";");
properties.setProperty("sasl.mechanism", "SCRAM-SHA-512"); properties.setProperty("sasl.mechanism", "SCRAM-SHA-512");
properties.setProperty("security.protocol", "SASL_SSL"); properties.setProperty("security.protocol", "SASL_SSL");
properties.setProperty("ssl.truststore.location", trustestore); properties.setProperty("ssl.truststore.location", "/opt/kafka/client.trustestore.p12");
properties.setProperty("ssl.truststore.password", "pwd123"); properties.setProperty("ssl.truststore.password", "pwd123");
}else{ }else{
properties.setProperty("bootstrap.servers", "10.0.10.153:29551,10.0.10.153:29552"); properties.setProperty("bootstrap.servers", "10.0.10.153:29551,10.0.10.153:29552");

Write Preview
Loading…
Cancel
Save