Что вы думаете о таком использовании ksql push query:
есть веб-сокет соединения, внутри коннекта каждого из соединений мы делаем push query к стриму. Например:
socket.on('connect', (event) => {
const data = kafka.query('select * from MY_STREAM where user_id = ${event.user_id} emit changes');
// todo something with data
})Меня беспокоит то, что если у нас много соединений по ведсокетам, мы создадим много пуш-кверей в ksqldb, что не думаю что хорошая идея. Так же, если я правильно понимаю, на каждый такой запрос будет создана отдельная query job которая будет крутится в ksqldb. Что тоже выглядит больно.
Что можете сказать про такой подход и чем он череват?
