При условии несовпадения данные живут в state столько же, сколько живет приложение. Когда совпадение однажды появляется, то оно мэтчится и отправляется свежим на приемник. Об СП попозже, но спойлер в него будут лететь только INSERT.
Проблем с чтением в разных тредах разные топики нет. Flink гарантирует синхронный вызов processElement1 в том порядке, в котором события доходят до этого оператора при условии, что данные партицируются через .keyBy и упорядочены на upstream операторах - то есть, если у меня события одинакового пользователя приходят в одну и ту же партицию, то эта партиция читается одним тредом и сохраняет порядок в контексте одной партиции, поэтому если в партиции уже упорядочены пользователи, то до потока они дойдут в том же порядке и на следующий оператор отправятся также при условии отсутствия доп. манипуляций.
При условии несовпадения данные живут в state столько же, сколько живет приложение.
Когда совпадение однажды появляется, то оно мэтчится и отправляется свежим на приемник.
Об СП попозже, но спойлер в него будут лететь только INSERT.
Да, вы правы. Поправил.
Проблем с чтением в разных тредах разные топики нет. Flink гарантирует синхронный вызов processElement1 в том порядке, в котором события доходят до этого оператора при условии, что данные партицируются через .keyBy и упорядочены на upstream операторах - то есть, если у меня события одинакового пользователя приходят в одну и ту же партицию, то эта партиция читается одним тредом и сохраняет порядок в контексте одной партиции, поэтому если в партиции уже упорядочены пользователи, то до потока они дойдут в том же порядке и на следующий оператор отправятся также при условии отсутствия доп. манипуляций.
kSQL возможен на простых задачах, но на задачах где надо делать CRUD на state и другие проблемы лучше выбирать более матерые инструменты.