apache-kafka-connect - KSQL 提交多个查询并保持运行

Question

我打算使用 KSQL 进行流处理。我有以下要求。

• 设置查询后，我想从查询中获取该输出并将其作为 JSON 发送到 RabbitMQ。

• 我有多个用户将为查询创建标准，我将采用该标准并将其转换为 KSQL 并提交给 KSQL 引擎。我想即时执行此操作，这样每当他们有新的过滤器要求时，我就不必一直插话自己。我将创建 UI 工具来捕获他们的标准，我的程序会将其转换为 KSQL 查询。

我还想保存来自多个用户的这些查询，以便在系统重新启动时我可以再次提交这些查询

我怎样才能做到这一点？

Answer 1

我可以通过一些 API 向 KSQL 引擎提交查询，还是在需要设置每个新查询时必须继续使用控制台？

是的，有一个 REST API，你也可以向服务器提交一个 SQL 文件以无头运行它。