String dir = "";
try {
dir = URLDecoder.decode(KafkaConsumerConfig.class.getClassLoader()
.getResource("").getPath(), "utf-8");
System.out.println("dir:" + dir);
} catch (UnsupportedEncodingException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.setProperty("java.security.auth.login.config", dir
+ "kafka_client_jaas.conf");
Spring boot kafka动态加载安全密匙路径代码
猜你喜欢
转载自blog.csdn.net/a15237851433/article/details/86589881
今日推荐
周排行