Scala应用中KsqlRestClient执行RUN SCRIPT需手动填充ksql.schema.file.content

我之前也踩过这个坑！问题核心在于RUN SCRIPT命令在REST API中的调用逻辑和CLI完全不同——你直接把RUN SCRIPT <script>字符串传给makeKsqlRequest是行不通的，因为KSQL Server的REST接口期望脚本内容通过请求体的特定字段传递，而非让服务器去解析语句里的路径。

关键原因解析 #

你看到的ksql.schema.file.content为空的提示就是突破口：这个字段就是用来承载脚本内容的。当你直接调用RUN SCRIPT ...时，这个字段没有被填充，所以服务器虽然返回"成功"状态，但实际上没有执行任何脚本逻辑。

正确调用方式 #

不要把脚本路径放在KSql语句里，而是构造包含两个核心参数的请求：

• ksql字段设为"RUN SCRIPT"（不需要带任何路径）
• ksql.schema.file.content字段设为你要执行的脚本的完整文本内容

下面是Scala的示例代码：

import io.confluent.ksql.api.client.KsqlRestClient
import java.util.HashMap

val client = KsqlRestClient.create("http://your-ksql-server:8088")
// 替换成你的脚本内容
val scriptContent = """
CREATE STREAM user_events (user_id INT, event_type STRING) WITH (
  KAFKA_TOPIC='user_events_topic',
  VALUE_FORMAT='JSON'
);
-- 这里可以添加脚本中的其他语句
""".trim

val requestParams = new HashMap[String, Any]()
requestParams.put("ksql", "RUN SCRIPT")
requestParams.put("ksql.schema.file.content", scriptContent)

val response = client.makeKsqlRequest(requestParams)
// 按需处理响应结果
client.close()

为什么之前的方式无效？ #

CLI里的RUN SCRIPT /path/to/script.sql是让本地CLI读取文件内容，再把内容发送给KSQL Server。但直接通过makeKsqlRequest传递这个语句时，服务器会把它当成普通KSql语句解析，找不到必填的ksql.schema.file.content参数，因此跳过脚本执行，只返回空的成功响应。

验证执行效果 #

执行完成后，你可以通过调用LIST STREAMS;或LIST TABLES;的KSql请求，检查脚本中定义的流、表是否已创建，以此确认脚本是否真正执行。

内容的提问来源于stack exchange，提问作者Christopher Beck