From c0b1d78e230a9ff2bfc05f19822cb867ba2565a0 Mon Sep 17 00:00:00 2001 From: Christian Alfoni Date: Sat, 2 Sep 2023 14:47:02 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B6=88=E8=B4=B9=E8=80=85=E5=8E=BB=E6=8E=89?= =?UTF-8?q?=E8=AE=A4=E8=AF=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/example/demokafka/util/KafkaUtil.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/main/java/com/example/demokafka/util/KafkaUtil.java b/src/main/java/com/example/demokafka/util/KafkaUtil.java index 6f37a92..fa5d44c 100644 --- a/src/main/java/com/example/demokafka/util/KafkaUtil.java +++ b/src/main/java/com/example/demokafka/util/KafkaUtil.java @@ -35,15 +35,15 @@ public class KafkaUtil { //keytool -keystore D:/keystore/client.trustestore.p12 -storepass pwd123 -noprompt -alias client.trustestore -import -file D:/keystore/ca.crt -storetype PKCS12 public static Properties getSafeConsumerPro() { Properties properties = new Properties(); - properties.setProperty("bootstrap.servers", "10.0.10.153:29551,10.0.10.153:29552,10.0.10.153:29553"); + properties.setProperty("bootstrap.servers", "10.0.10.153:29551,10.0.10.153:29552"); properties.setProperty("group.id", "isv-kafka"); properties.setProperty("key.deserializer", StringDeserializer.class.getName()); properties.setProperty("value.deserializer", StringDeserializer.class.getName()); - 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("security.protocol", "SASL_SSL"); - properties.setProperty("ssl.truststore.location", trustestore); - properties.setProperty("ssl.truststore.password", "pwd123"); +// 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("security.protocol", "SASL_SSL"); +// properties.setProperty("ssl.truststore.location", trustestore); +// properties.setProperty("ssl.truststore.password", "pwd123"); properties.setProperty("enable.auto.commit", "true"); properties.setProperty("auto.commit.interval.ms", "1000"); properties.setProperty("session.timeout.ms", "30000");