diff --git a/src/main/java/com/example/demokafka/util/KafkaUtil.java b/src/main/java/com/example/demokafka/util/KafkaUtil.java
index 977c637..5e3580c 100644
--- a/src/main/java/com/example/demokafka/util/KafkaUtil.java
+++ b/src/main/java/com/example/demokafka/util/KafkaUtil.java
@@ -28,7 +28,8 @@ public class KafkaUtil {
         properties.setProperty("acks", "all");
         properties.setProperty("key.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("security.protocol", "SASL_SSL");
         properties.setProperty("ssl.truststore.location", trustestore);
@@ -48,10 +49,10 @@ public class KafkaUtil {
         properties.setProperty("value.deserializer", StringDeserializer.class.getName());
         if (StringUtils.isNotBlank(appCode)) {
             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("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");
         }else{
             properties.setProperty("bootstrap.servers", "10.0.10.153:29551,10.0.10.153:29552");