没有数据进入基于ksql二进制文件流构建的表中,如果我对ksql prompt执行相同的操作,它会出现吗?

eanckbw9  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(221)

我正在尝试使用ksql二进制文件在流上创建一个表。表被创建并开始运行,但是当我查询它时,表中没有数据。当我使用ksql提示符创建相同的表时,我也能够查询数据。
ps:我正在设置这个属性集'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 prompt open时也是一样,它按原样工作。
我希望有一种方法可以创建一个表并查询它,而不必使用ksql提示符。

tyg4sfes

tyg4sfes1#

你需要设置 SET 'auto.offset.reset'='earliest'; 在你的 CREATE 查询。
如果您想通过脚本与ksql交互,我建议您使用restapi(例如,通过 curl )而不是尝试通过管道连接到ksql二进制文件。

相关问题