У меня есть вариант использования, когда у меня есть 2 темы в Kafka, одна тема - ABC, а другая тема - CDE, данные в теме в CDE используются в вычислениях, и их размер не так велик, поэтому мы хотим заполнить карту памяти с помощью эти данные, а затем использовать эту карту в вычислениях с данными из раздела ABC. Итак, на шаге 1, когда компонент запускается, я хочу заполнить карту всеми данными в CDE, прежде чем использовать какое-либо сообщение от ABC, и при выполнении любой обработки данных, полученных из темы ABC, я проверю, есть ли в теме неиспользованное сообщение CDE, если да, обновите кеш и используйте результаты кеширования. Как этого добиться с помощью Spring Cloud Stream
На самом деле это не относится к весеннему потоку облаков. Заполнение кеша является обязанностью инициализации / запуска, поэтому вопрос не в том, как это может быть достигнуто с помощью spring-cloud-stream, а скорее в том, как это может быть достигнуто. Я имею в виду, что, конечно, вы можете что-то взломать с помощью spring-cloud-stream, все, что я говорю, это то, что это не было разработанным вариантом использования, когда слушателю придется загружать некоторый кеш.
Существует множество систем и технологий кэширования, и хотя это выходит за рамки этого канала, на этом форуме есть каналы, которые могут помочь - stackoverflow.com/questions/tagged/caching
Спасибо за то, что поделились знаниями, поэтому я бы перефразировал вопрос о том, как лучше всего поддерживать кеш для такого рода сценариев?