KSQL Отправка нескольких запросов и поддержание их работы

Question

Я планирую использовать KSQL для потоковой обработки. У меня есть следующие требования.

• Как только запрос настроен, я хочу получить этот вывод из запроса и отправить его как JSON в RabbitMQ.

• У меня есть несколько пользователей, которые будут создавать критерии для запроса, и я буду использовать эти критерии, преобразовывать их в KSQL и отправлять в механизм KSQL. Я хочу сделать это на лету, чтобы мне не приходилось постоянно вставлять себя, когда они предъявляют новые требования к фильтру. Я буду создавать инструмент для пользовательского интерфейса, чтобы получить их критерии, и моя программа преобразует это в запрос KSQL.

Также я хочу сохранить эти запросы от нескольких пользователей, чтобы при перезапуске системы я мог снова отправить эти запросы

Как мне этого добиться?

Answer 1

Могу ли я отправлять запросы в движок KSQL через некоторый API или мне нужно продолжать использовать консоль, когда необходимо настроить каждый новый запрос?

Да, есть REST API, и вы также можете отправить файл SQL на сервер, чтобы запустить его в автономном режиме.