没有数据进入 table 基于 ksql 二进制流构建的数据，如果我对 ksql 提示执行相同操作，它会到达那里吗？

Question

我正在尝试使用 ksql 二进制文件在流上创建 table。 table 被创建并开始 运行ning，但是当我查询它时 table 中没有数据。当我使用 ksql 提示创建相同的 table 时，我也可以查询数据。

PS：我设置这个属性 SET 'auto.offset.reset'='earliest';以查询数据表开头。

两种方法我都试过了。它在我使用 ksql 提示符创建 table 时起作用。当尝试对 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 提示符打开它时也是如此。

我期待一种创建 table 并在不使用 ksql 提示符的情况下查询它的方法。

Answer 1

您需要在 CREATE 查询之前设置 SET 'auto.offset.reset'='earliest';。

如果你想通过脚本与 KSQL 交互，我建议使用 REST API（例如通过 curl），而不是尝试通过管道传输到 ksql 二进制文件。