Чтение сообщений от внешнего брокера в Spring Data Flow
Я работаю над архитектурой Spring Data Flow + Kafka, которую я развернул в кластере Kubernetes.
У нас есть общедоступный REST API (загрузочное приложение Spring за пределами кластера Kubernetes), который отправляет сообщение в концентратор событий Azure.
Теперь мы хотим, чтобы этот API инициировал потоки в Spring Data Flow, у меня было две идеи для этого, но я не уверен, как их реализовать:
- Разработка приложения Spring Data Flow Source, способного читать сообщения в концентраторе событий Azure: но я не понимаю, нужно ли мне объявлять концентратор событий в качестве связующего?
- Отправляйте сообщения непосредственно из нашего API в экземпляр Kafka Spring Data Flow: это хорошая практика? Могу ли я использовать любую тему в Kafka и использовать ее в качестве источника процессора?
Может быть, я что-то упускаю в этой архитектуре, но, прочитав множество документации, я так и не понял, как добиться связи с нашим API.
Спасибо