2 个 kafka 消费者从 2 个具有不同 SSL 配置的不同主题中读取

2 kafka consumers to read from 2 different topics with different SSL configuration

我正在编写一个 Spring 启动应用程序,它将使用 2 个不同的主题并处理消息。这 2 个主题托管在不同的集群上,并具有不同的 SSL 配置。 我想创建 2 个不同的消费者来阅读主题。 我正在使用 Spring-cloud-stream 和 kafka-stream。 关于如何为这种情况设置 application.properties 的任何帮助?

根据您的描述,您正在创建两个独立的微服务。

为什么要将它们合并到一个应用程序中?这种做法违背了微服务的目的,从根本上违背了 spring-cloud-stream 作为框架的设计和目的。您是否考虑过未来的管理、维护、支持等?基本上我的意思是这两个消费者由于资源共享(内存,CPU 等)而相互依赖。

我同意@oleg-zhurakoussky 的回答。但是,如果您无论如何都想这样做,我建议您查看 Spring FactoryBean。