Spring启动Kafka：如何配置两个 jaas 配置文件

Question

我有一个spring boot kafka客户端应用程序，其中有两个消费者在kafka中收听不同的主题和不同的消费者群。

为了实现，我需要下面有两个JAAS会议(使用不同的keytab文件)

dc-jaas-A.conf文件

    KafkaClient {
        com.sun.security.auth.module.Krb5LoginModule required
        useKeyTab=true
        storeKey=true
        useTicketCache=false
        serviceName="kafka"
        keyTab="testA.keytab"
        principal="[e-mail]";
    };

dc-jaas-B.conf

    KafkaClient {
        com.sun.security.auth.module.Krb5LoginModule required
        useKeyTab=true
        storeKey=true
        useTicketCache=false
        serviceName="kafka"
        keyTab="testB.keytab"
        principal="[e-mail]";
    };

由于下面的connect tFactory在System.setProperty中设置dc-jaas-A.conf和dc-jaas-B.conf，该值被覆盖，结果我得到"org.apache.kafka.common.errors.TopicAuthorizationException"异常。

 @Bean
    public ProducerFactory<String, String> producerFactoryForA() {
        System.setProperty("java.security.auth.login.config", "C:/Users/Files/dc-jaas-A.conf");
        System.setProperty("java.security.krb5.conf","C:/Users/Files/krb5.conf");
        Map<String, Object> configs = new HashMap<>();
        configs.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
       // more configs here
        return new DefaultKafkaProducerFactory<>(configs);
    }
     @Bean
    public ProducerFactory<String, String> producerFactoryForB() {
        System.setProperty("java.security.auth.login.config", "C:/Users/Files/dc-jaas-B.conf");
        System.setProperty("java.security.krb5.conf","C:/Users/Files/krb5.conf");
        Map<String, Object> configs = new HashMap<>();
        configs.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServers);
       // more configs here
        return new DefaultKafkaProducerFactory<>(configs);
    }

Answer 1

这是不可能的，至少在java 8中是这样。JAAS类在内部使用静态结构来维护kerberos配置。

每次在使用令牌之前，您都必须初始化/刷新krb配置。

另一个解决方法是对两个SPN使用相同的keytab文件。Keytab可以包含多个SPN条目。