消费者去掉认证

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