Один @StreamListener в зависимости от другого @StreamListener

Question

У меня есть сценарий использования, в котором у меня есть 2 темы в Kafka, одна тема - ABC, а другая - CDE, данные в теме в CDE используются в вычислениях и имеют небольшой размер, поэтому мы хотим заполнить их.Карта памяти с этими данными, а затем с помощью этой карты в расчетах с данными из темы ABC.Поэтому, начиная с шага 1, когда компонент запускается, я хочу заполнить карту всеми данными в CDE, прежде чем использовать какое-либо сообщение от ABC, и при выполнении какой-либо обработки данных, полученных из темы ABC, я проверю, есть ли в теме неиспользованное сообщение.CDE, если да, обновите кеш и используйте результаты кеша.Как этого добиться, используя Spring Cloud Stream

Answer 1

Это действительно не так для весеннего облачного потока.Заполнение кэша является обязанностью инициализации / запуска, поэтому на самом деле вопрос не в том, как этого можно достичь с помощью Spring-Cloud-Stream, а в том, как этого можно достичь.Я имею в виду, конечно, что вы можете взломать что-нибудь, используя spring-cloud-stream, все, что я хочу сказать, это то, что он не был разработан для случая, когда слушателю придется загружать некоторый кеш.