|
对于最新的稳定版本，请使用 Spring for Apache Kafka 3.2.1！ |
|
对于最新的稳定版本，请使用 Spring for Apache Kafka 3.2.1！ |
从 2.0 版开始，添加了一个类来帮助进行 Kerberos 配置。
您可以将具有所需配置的此 Bean 添加到应用程序上下文中。
以下示例配置这样的 Bean：KafkaJaasLoginModuleInitializer
@Bean
public KafkaJaasLoginModuleInitializer jaasConfig() throws IOException {
KafkaJaasLoginModuleInitializer jaasConfig = new KafkaJaasLoginModuleInitializer();
jaasConfig.setControlFlag("REQUIRED");
Map<String, String> options = new HashMap<>();
options.put("useKeyTab", "true");
options.put("storeKey", "true");
options.put("keyTab", "/etc/security/keytabs/kafka_client.keytab");
options.put("principal", "[email protected]");
jaasConfig.setOptions(options);
return jaasConfig;
}