从 spring boot 应用程序运行 KSQL 的方式是什么

Question

我有一个连接到 kafka 集群的 Spring Boot 应用程序。如何从 Java 代码运行 KSQL？

Answer 1

目前，还没有直接的方法可以将 KSQL 用作 Java 中的库。同样有一个未解决的问题#734。

但是您可以使用 REST API 运行 KSQL 语句，并且该实现可以在 Spring Boot 应用程序中完成。一个 Rest 调用看起来像这样：

POST /query HTTP/1.1
Accept: application/vnd.ksql.v1+json
Content-Type: application/vnd.ksql.v1+json

{
  "ksql": "SELECT * FROM pageviews;",
  "streamsProperties": {
    "ksql.streams.auto.offset.reset": "earliest"
  }
}

// Through Curl 
curl -X "POST" "http://localhost:8088/ksql" \
     -H "Content-Type: application/vnd.ksql.v1+json; charset=utf-8" \
     -d $'{
  "ksql": "LIST STREAMS;",
  "streamsProperties": {}
}'

您可以在此处找到文档：https :
//docs.confluent.io/current/ksql/docs/developer-guide/api.html#rest-endpoint