Всем привет. Может кто подскажет )) есть задача реализовать CEP. Предлагают воспользоваться Flink + Kafka.
Должно работать так. Данные с отдельных таблиц в БД через некий коннектор попадают в кафка-топики. Приложение их читает, джойнит, обогащает, в результате чего получается готовое событие по пользователю. Далее эти события записываются в локальное хранилище (state store). По каждому пользователю эти события добавляются/обновляются/удаляются - пока в итоге не будет получено целевое.
По целевым событиям необходимо выполнить определенную реакцию. Т.е. этот стор нужно опрашивать, и если по временным показателям нужно выполнить действие, то делаем.
Предполагается большой поток данных на входе, нужно горизонтально масштабироваться. То есть система должна работать в режиме кластера.
Вопрос: насколько предлагаемые технологии подходят под эту задачу?
М.б. какие-то нюансы есть при их использовании?
Или какие бест-практис решения можно взять под такую задачу?