ksqldb - spring boot app运行KSQL的方式是什么

Question

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

Answer 1

目前，还没有直接的方法将KSQL 用作java 中的库。有一个开放的issue#734同样。

但是您可以使用 REST API 运行 KSQL 语句，并且该实现可以在 Spring Boot 应用程序中完成。休息电话看起来像这样:

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