1个kafka client 访问2个不同的有验证权限的kafka 服务,java.security.auth.login.config 该如何配置,以满足2个配置文件

big big world 发表于: 2019-06-20   最后更新时间: 2021-08-13 10:03:11   6,393 游览

一个 kafka client 访问2个不同的kafka 服务,都需要jaas 验证授权,java.security.auth.login.config 这个属性指定jaas配置文件,因为有2个不同的kafka服务,所以有2个jaas配置文件,那 System.setProperty("java.security.auth.login.config","");这里改如何配置以满足2方验证授权呢? java.security.auth.login.config 这个属性在 kafka-client jar 里是写死的

发表于 2019-06-20
添加评论

System.setProperty是全局的.. 我先想想。

老哥,有方法嘛?

先试试这种类似的。

Properties props = new Properties();
.......
// 增加ssl验证
props.put("security.protocol", "SSL");
props.put("ssl.truststore.password", "test1234");
props.put("ssl.truststore.location","/Users/weiwei/Downloads/client.truststore.jks");

直接把jaas配置文件内容,作为 producer 这个sasl.jaas.config属性 value,可以试试

老哥,你这个问题解决了吗?我也遇到了这个问题,有点不知道怎么弄

你的答案

查看kafka相关的其他问题或提一个您自己的问题