Spring boot kafka动态加载安全密匙路径代码

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

猜你喜欢

转载自blog.csdn.net/a15237851433/article/details/86589881
今日推荐