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", "[email protected]");
    jaasConfig.setOptions(options);
    return jaasConfig;
}