我正在尝试将我的spring-boot应用程序与具有不同安全配置的多个kafka资源连接起来。第一个kafka源具有默认的明文安全协议，而第二个源具有saslèu明文。
因此，我需要配置多个使用者：
对于具有明文协议的kafka示例
对于kafka示例，使用sasl\u明文协议和 sasl.mechanism & sasl.jaas.config 有什么办法可以实现这个wia-java配置吗？我找到了可使用的配置类https://kafka.apache.org/24/javadoc/org/apache/kafka/common/config/saslconfigs.htmlhttpshttp://kafka.apache.org/24/javadoc/org/apache/kafka/clients/admin/adminclientconfig.html
但我不知道如何使用它的多Kafka源配置。
谢谢你的帮助。
1条答案
按热度按时间v6ylcynt1#
SpringBoot只会自动配置一套生产和消费工厂；如果您需要多个，那么您需要自己配置这两个集合（仅配置第二个集合将禁用boot的自动配置）。
https://docs.spring.io/spring-kafka/docs/2.5.5.release/reference/html/#connecting