如题,在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

 

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐