2 потребителя кафки для чтения из 2 разных тем с различной конфигурацией SSL

Question

Я пишу загрузочное приложение Spring, которое будет использовать две разные темы и обрабатывать сообщение. Эти 2 темы размещены в разных кластерах и имеют разные конфигурации SSL. Я хочу создать 2 разных потребителей для чтения из тем. Я использую Spring-cloud-stream и kafka-stream. Любая помощь о том, как настроить application.properties для этого сценария?

Answer 1

На основании того, что вы описали, вы создаете два независимых микросервиса.

Зачем объединять их в одно приложение? Такого рода поражение цели микросервиса и принципиально идет вразрез с дизайном и целью Spring-Cloud-Stream в качестве основы. Вы думали о будущем управлении, обслуживании, поддержке и т. Д.? По сути, я имею в виду, что эти два потребителя зависят друг от друга из-за совместного использования ресурсов (память, процессор и т. Д.).

Answer 2

Я согласен с ответом @ oleg-zhurakousky. Однако, если вы хотите сделать это независимо, я рекомендую вам взглянуть на Spring FactoryBean.