diff --git a/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/RealConsumer.java b/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/RealConsumer.java
index 0dc95102..2d6ae101 100644
--- a/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/RealConsumer.java
+++ b/stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/RealConsumer.java
@@ -87,6 +87,10 @@ public class RealConsumer implements CommandLineRunner {
             }
             logger.info("Security prepare success.");
         }
+        kafkaProp.put("security.protocol","SASL_PLAINTEXT");
+//        System.setProperty("java.security.auth.login.config","/gpsstore/kafka_client_scram_consumer_jaas.conf");
+        kafkaProp.put("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"admin\" password=\"admin-2024\";");
+        kafkaProp.put("sasl.mechanism", "PLAIN");
 
         KafkaConsumerRunnable runnable = new KafkaConsumerRunnable(kafkaProp,dtpExecutor2,cityCode);
         executorService.execute(runnable);