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