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

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

Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
0
0
56
1

Ответы 1

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

Спасибо за то, что поделились знаниями, поэтому я бы перефразировал вопрос о том, как лучше всего поддерживать кеш для такого рода сценариев?

Muhammad Sufyian 23.10.2018 18:12

Существует множество систем и технологий кэширования, и хотя это выходит за рамки этого канала, на этом форуме есть каналы, которые могут помочь - stackoverflow.com/questions/tagged/caching

Oleg Zhurakousky 23.10.2018 19:14

Другие вопросы по теме