From 3bd524964becf6e771a432caf5c1626c9675fa01 Mon Sep 17 00:00:00 2001 From: luyya Date: Tue, 26 Aug 2025 16:45:33 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=9A=E4=BD=8D=E6=95=B0=E6=8D=AE=E4=B8=8A?= =?UTF-8?q?=E6=8A=A5=E7=9C=81=E5=8E=85=E9=93=9C=E9=99=B5=E7=89=88=E6=9C=AC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/org/dromara/data2kafka/consumer/RealConsumer.java | 4 ++++ 1 file changed, 4 insertions(+) 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);