ly
/
Stwzhj-Cloud-Plus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

定位数据上报省厅铜陵版本

stwzhj
luyya 2025-08-26 16:45:33 +08:00
parent a01837bf6d
commit 3bd524964b
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
stwzhj-modules/stwzhj-data2StKafka/src/main/java/org/dromara/data2kafka/consumer/RealConsumer.java
View File

@ -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);