在scala应用程序中,我试图告诉ksql服务器它应该执行 RUN SCRIPT <script>
命令,使用 KsqlRestClient.makeKsqlRequest(String ksql)
功能。每次尝试时,都没有发生任何事情,即使响应是成功的,所以我开始调试,我看到响应是成功的,但它也返回了某种错误,即ksql.schema.file.content属性为空。
因为我没有找到任何关于填充此属性的文档,所以我尝试了一些方法,最终发现如果用.sql文件的内容填充此属性,run script命令就可以工作。
有没有人知道ksql.schema.file.content通常应该填充什么和/或我使用它的方式是如何从scala应用程序执行ksql脚本。我已经将makeksqlrequest中的文本复制并粘贴到ksqlcli中,一切正常,因此应该没有错误。
1条答案
按热度按时间js4nwp541#
有一个github问题跟踪到restfulapi还没有被记录/支持的事实(截至2018年3月)。
这听起来像是你需要添加一个
+1
我也是。