Никакие данные не попадают в таблицу, построенную по потоку из двоичного файла ksql, это получится, если я сделаю то же самое с приглашением ksql?

Question

Я пытаюсь создать таблицу в потоке, используя двоичный файл ksql. Таблица создается и запускается, но когда я запрашиваю ее, внутри таблицы нет данных. Когда я создаю то же самое, используя приглашение ksql, создается таблица, я также могу запрашивать данные.

PS: я устанавливаю это свойство SET 'auto.offset.reset' = 'наиболее ранние'; запросить начало формы данных.

Я пробовал оба метода. Это работает, когда я создаю таблицу, используя приглашение ksql. Та же команда не работает при попытке сделать то же самое с двоичным кодом ksql.

sudo echo "CREATE TABLE movie_table AS SELECT title, count(*) AS appearance FROM test WHERE year > 1988 GROUP BY title;" | sh /home/binary/ksql http://devopsksql.default.svc.cluster.local:8088

ksql> CREATE TABLE movie_table AS SELECT title, count(*)

 Message
---------------------------
 Table created and running
---------------------------

ksql> select * from MOVIE_TABLE;
^CQuery terminated

То же самое, когда я запускаю с открытым приглашением ksql, оно работает как есть.

Я ожидаю, как создать таблицу и запросить ее, не используя приглашение ksql.

Answer 1

Вам необходимо установить SET 'auto.offset.reset'='earliest'; перед запросом CREATE.

Если вы хотите взаимодействовать с KSQL из сценария, я бы предложил использовать REST API (например, через curl), чем пытаться передать в двоичный файл ksql.