KSQL REST API не требует времени для ответа

Я столкнулся с проблемой при вызове конечной точки KSQL Rest для выполнения запроса, мой запрос:

выберите * из потока 1, где = 123 предел 3;

Я отправляю его в теле почтового запроса следующим образом:

{"ksql": "SELECT * FROM stream1, где id = 3 LIMIT 3; ", "streamsProperties": {"ksql.streams.auto.offset.reset": "earliest"} }

несколько раз он отвечает в течение 1 секунды, а иногда - в течение 5 секунд, а иногда - в течение 10 секунд.

В потоке есть данные большого размера, всего пара сообщений;

Есть ли способ исправить эту проблему, или мы должны использовать Postgress, MySQL..., чтобы решить эту проблему.

0 ответов

Остальная конечная точка в версии ksql, которую вы используете, не предназначена для использования в качестве способа запроса потоков и таблиц с уровня приложения. В первую очередь он был разработан для использования людьми через интерфейс командной строки.

По этой причине он не оптимизирован для того типа операций, которые вы пытаетесь выполнить.

В следующем выпуске ksqlDB (0.10.x) будет новый клиентский API, который может позволить вам делать то, что вы хотите.

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