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

big big world 发表于: 2019-06-20   最后更新时间: 2019-06-20  

一个 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 里是写死的



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容





发表于: 2月前   最后更新时间: 2月前   游览量:428
上一条: kafka如何做到先启动producer生产消息,然后再启动consumer消费消息呢?
下一条: zookeeper 无法启动

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