Spring Kafka 多客户端配置

Question

我正在尝试将我的 spring-boot 应用程序与具有不同 sicurity 配置的多个 kafka 资源连接起来。第一个 kafka 源具有默认的 PLAINTEXT 安全协议，而第二个源具有 SASL_PLAINTEXT。

所以我需要配置多个消费者：

1. 对于带有 PLAINTEXT 协议的 kafka 实例
2. 用于带有 SASL_PLAINTEXT 协议和sasl.mechanism & sasl.jaas.config 的 kafka 实例

有什么方法可以实现这个 wia java 配置吗？ 我找到了合适的配置类 https://kafka.apache.org/24/javadoc/org/apache/kafka/common/config/SaslConfigs.html https://kafka.apache.org/24/javadoc/org/apache/kafka/clients/admin/AdminClientConfig.html

但我不知道如何将它用于多个 kafka 源配置。

感谢您的帮助。

Answer 1

Spring Boot 只会自动配置一组生产者和消费者工厂；如果你需要多个，那么你需要自己配置两个集合（只需配置第二个将禁用 Boot 的自动配置）。

https://docs.spring.io/spring-kafka/docs/2.5.5.RELEASE/reference/html/#connecting