idea中,java如何实现连接带有kerberos认证的kafka环境,以及ICMP Port Unreachable的解决办法
如题,在Java本地开发环境中,如果需要测试kafka kerberos认证,和linux系统有什么区别呢?前提 :首先拥有带有kerberos的kafkahu环境,其次读者可以自行连接普通没有认证的kafka环境。本文通过简单的代码片段详解。如下:首先,需要具备kerberos认证的文件,主要包含keytab和jaas.conf其次,代码中需要设置认证方式设置jvm参数-Djava.securi
·
如题,在Java本地开发环境中,如果需要测试kafka kerberos认证,和linux系统有什么区别呢?
前提 :首先拥有带有kerberos的kafkahu环境,其次读者可以自行连接普通没有认证的kafka环境。
本文通过简单的代码片段详解。如下:
首先,需要具备kerberos认证的文件,主要包含keytab和jaas.conf
其次,代码中需要设置认证方式
设置jvm参数
-Djava.security.auth.login.config=F:\\xxx\\kerberos\\kafka_client_jaas.conf -Djava.security.krb5.conf=F:\\xxx\\kerberos\\krb5.conf
启动验证
验证结果
注意,如果不设置krb5.conf配置,可能会出现ICMP Port Unreachable
更多推荐
已为社区贡献1条内容
所有评论(0)