apache-kafka - 如何验证ksql脚本?

标签 apache-kafka ksqldb

我想知道是否有办法检查 .ksql 是否存在脚本语法正确吗?

我知道您可以发送 POST向服务器发出请求,但这也会执行包含的 ksql 命令。我希望有某种端点,您可以在其中传递语句,它会返回错误代码或 OK,例如:

curl -XPOST <ksqldb-server>/ksql/validate -d '{"ksql": "<ksql-statement>"}' .

我的问题旨在寻找一种以自动方式检查 synatx 的方法,而无需事后清理所有内容。

感谢您的帮助!

注意:我也很清楚我可以使用 docker-compose 单独运行所有内容。再次归档并撕毁所有内容。然而,这非常耗费资源并且更难维护。

最佳答案

一个选项可能是使用 ksql 测试运行程序(请参见此处: https://docs.ksqldb.io/en/latest/how-to-guides/test-an-app/ )并查看错误以检查语句是否有效。让我知道它是否适合您的场景。

关于apache-kafka - 如何验证ksql脚本?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/70380093/

相关文章:

apache-kafka - KSQL 表是否应该为聚合的每个键显示多行?

json - ksql json 字段名带有破折号 (-)

apache-kafka - KafkaStream createTopic 不尊重 Kafka 服务器的 auto.create.topics.enable 设置

kubernetes - 如何从 kubernetes 集群内提供的服务访问安装在 kubernetes 集群外的 kafka

apache-kafka - KSQLDB Emit Final 不返回任何值

ksqldb - ksqlDB表中的数据是持久的吗?

unity3d - Unity 中的 Kafka 消费

ssl - 如何向 Kafka Websocket 代理服务器开放安全 Websocket (WSS)

apache-kafka - 阅读所有消息后,终止Kafka Console使用者

c# - 有没有办法从 .NET 使用 Kafka Ksql 推送查询