Хранение запросов и таблиц KSQL

Question

Я искал документацию о том, где KSQL запрашивает хранилище и таблицы. Например, поскольку KSQL был создан для работы с Kafka, когда я создаю таблицу из темы или когда я пишу запрос, где хранятся таблицы или результаты запроса? В частности, использует ли KSQL какие-либо указатели на события внутри сегментов внутри тематических разделов или дублирует события, например, когда я создаю таблицу из темы?

Answer 1

Запросы, которые были выполнены или являются активными, снова возвращаются в тему Кафки.

Оператор Select не имеет постоянного состояния - он действует как потребитель

Команда Create Stream / Table создаст потенциально много тем, что приведет к дублированию, манипуляции и фильтрации входной темы. в заданную тему назначения. Для любых операций с состоянием результаты будут храниться в экземпляре RocksDB на серверах KSQL.

Поскольку KSQL построен на Kafka Streams, вы можете обратиться к вики на Kafka Streams Внутреннее управление данными