JAAS和Kerberos导弹

从2.0版本开始，aKafkaJaasLoginModuleInitializer新增了该级别以协助Kerberos配置。 你可以将这个豆子和所需的配置添加到你的应用上下文中。 以下示例配置了这样一个豆子：spring-doc.cadn.net.cn

@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;
}