使用 Spring Kafka 续订 Kerberos 票证

Question

我们已经在我们的 kafka 集群中实现了 kerberos recently.Clients 需要使用 SASL_SSL 来与之对话 cluster.As 我们在我们的项目中使用 spring-kafka，我来自 spring documentation.I 的 KafkaJaasLoginModuleInitializer 模块认为我们可以利用此功能，但想了解它是否提供任何功能来在票过期时更新票（可能在不同的线程上）。我查看了代码，发现地图中传递的选项随后用于启动 javax.security.auth.login.AppConfigurationEntry 实例，但没有看到自动续订的方法。

Answer 1

正确，它只是提供 -Djava.security.auth.login.config JVM 参数的 Spring 友好替代方法。

更新 kerberos 票证不在 Apache Kafka Spring 的范围内；所有与代理连接相关的操作都委托给 kafka-clients；参考 Kafka 文档。