From f24eafc1ecf17895ff69fe1bde40df5d33f9048c Mon Sep 17 00:00:00 2001
From: zhouwentao <1577701412@qq.com>
Date: Thu, 21 Sep 2023 17:26:03 +0800
Subject: [PATCH] updates

---
 src/main/java/com/example/zxweb/utils/KafkaUtil.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/example/zxweb/utils/KafkaUtil.java b/src/main/java/com/example/zxweb/utils/KafkaUtil.java
index 1690053..776d7d0 100644
--- a/src/main/java/com/example/zxweb/utils/KafkaUtil.java
+++ b/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 (StringUtils.isNotBlank(appCode)) {
             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,9 +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");