ksqlrestclient.makeksqlrequest(“运行脚本…”)如果不自己用脚本内容填充ksql.schema.file.content,则无法工作

qoefvg9y  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(156)

在scala应用程序中,我试图告诉ksql服务器它应该执行 RUN SCRIPT <script> 命令,使用 KsqlRestClient.makeKsqlRequest(String ksql) 功能。每次尝试时,都没有发生任何事情,即使响应是成功的,所以我开始调试,我看到响应是成功的,但它也返回了某种错误,即ksql.schema.file.content属性为空。
因为我没有找到任何关于填充此属性的文档,所以我尝试了一些方法,最终发现如果用.sql文件的内容填充此属性,run script命令就可以工作。
有没有人知道ksql.schema.file.content通常应该填充什么和/或我使用它的方式是如何从scala应用程序执行ksql脚本。我已经将makeksqlrequest中的文本复制并粘贴到ksqlcli中,一切正常,因此应该没有错误。

js4nwp54

js4nwp541#

有一个github问题跟踪到restfulapi还没有被记录/支持的事实(截至2018年3月)。
这听起来像是你需要添加一个 +1 我也是。

相关问题