一个 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,可以试试
老哥,你这个问题解决了吗?我也遇到了这个问题,有点不知道怎么弄
你的答案