我们最近在kafka集群中实现了kerberos。客户端需要使用sasl\u ssl与这个集群进行通信。因为我们在项目中使用spring kafka,我在spring文档中遇到了这个kafkajaasloginmoduleinitializer模块,我认为我们可以利用这个功能,但是我想了解它是否提供了在票证过期时续订票证的功能(可能在另一个线程上)。我查看了代码,发现Map中传递的选项随后被用于启动javax.security.auth.login.appconfigurationentry示例,但没有找到进行自动续订的方法。
1条答案
按热度按时间smdnsysy1#
正确,它只是提供
-Djava.security.auth.login.config
jvm参数。更新kerberos票证超出了apachekafka的spring范围;所有与代理连接相关的操作都委托给kafka客户机;参考Kafka文献。