updates

src/main/java/com/example/zxweb/utils/KafkaUtil.java

@@ -56,7 +56,7 @@ public class KafkaUtil {
         properties.setProperty("group.id", "isv-kafka");
         properties.setProperty("key.deserializer", StringDeserializer.class.getName());
         properties.setProperty("value.deserializer", StringDeserializer.class.getName());
-        /*if (StringUtils.isNotBlank(appCode)) {
+        if (false) {
             System.out.println("使用鉴权");
             properties.setProperty("bootstrap.servers", "10.0.10.153:29553,10.0.10.153:29554");
             properties.setProperty("sasl.jaas.config", "org.apache.kafka.common.security.scram.ScramLoginModule required username=\"dwVendor\" password=\"fEVcb^QFB;IN$K5\";");
@@ -64,10 +64,9 @@ public class KafkaUtil {
             properties.setProperty("security.protocol", "SASL_SSL");
             properties.setProperty("ssl.truststore.location", trustestore);
             properties.setProperty("ssl.truststore.password", "pwd123");
-        }else{*/
+        }else{
             properties.setProperty("bootstrap.servers", "10.0.10.153:29551,10.0.10.153:29552");
-        /*}*/
-
+        }
         properties.setProperty("enable.auto.commit", "true");
         properties.setProperty("auto.commit.interval.ms", "1000");
         properties.setProperty("session.timeout.ms", "5000");