JAAS 与 Kerberos

Doubao 中英对照 JAAS and 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;
}