Как запустить KSQL из весеннего загрузочного приложения?

Question

У меня есть приложение весенней загрузки, которое подключено к кластеру kafka. Как я могу запустить KSQL из кода Java?

Answer 1

На данный момент нет прямого способа использовать KSQL в качестве библиотеки в Java. Существует открытая проблема # 734 для того же.

Но вы можете запустить оператор KSQL с помощью REST API, и эту реализацию можно выполнить в Spring Boot Application. Вызов отдыха будет выглядеть примерно так:

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