From 1138df89da3d818136794a0ec6a99c5bf4e27d4b Mon Sep 17 00:00:00 2001 From: zhouwentao <1577701412@qq.com> Date: Wed, 6 Sep 2023 15:21:53 +0800 Subject: [PATCH] updates --- src/main/java/com/example/demokafka/util/KafkaUtil.java | 1 + 1 file changed, 1 insertion(+) diff --git a/src/main/java/com/example/demokafka/util/KafkaUtil.java b/src/main/java/com/example/demokafka/util/KafkaUtil.java index 5e3580c..2591ccb 100644 --- a/src/main/java/com/example/demokafka/util/KafkaUtil.java +++ b/src/main/java/com/example/demokafka/util/KafkaUtil.java @@ -48,6 +48,7 @@ public class KafkaUtil { properties.setProperty("key.deserializer", StringDeserializer.class.getName()); properties.setProperty("value.deserializer", StringDeserializer.class.getName()); 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\";"); properties.setProperty("sasl.mechanism", "SCRAM-SHA-512");