JAAS 和 Kerberos
从版本 2.0 开始,添加了一个 KafkaJaasLoginModuleInitializer
类,以帮助进行 Kerberos 配置。您可以将此 bean 及其所需的配置添加到您的应用程序上下文中。以下示例配置了这样的 bean:
@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", "kafka-client-1@EXAMPLE.COM");
jaasConfig.setOptions(options);
return jaasConfig;
}