如何在 Spring Boot 应用程序中使用嵌入式 sql?

How to use EmbeddedKsql in SpringBoot application?

我有 Kafka Streams java 应用程序并 运行ning。我试图使用 KSQL 来创建简单的查询,并使用 Kafka Stream 来创建复杂的解决方案。我想 运行 KSQL 和 Kafka Streams 作为 Java申请。

我正要完成 https://github.com/confluentinc/ksql/blob/master/ksqldb-examples/src/main/java/io/confluent/ksql/embedded/EmbeddedKsql.java。有没有 EmbeddedKsql 的文档?或任何工作原型?

KsqlDB 服务器目前不支持 Java API。该项目不提供任何维护版本之间兼容性的保证。

如果您要将 运行 ksqlDB 嵌入到您的 Java 应用程序中,那么 KsqlContext 将是 class 可以使用的。但我不确定它有多新,也不能保证它不会在未来的版本中被删除。恐怕没有任何文档或示例可供查看,因为它不受支持。

唯一受支持的与 ksqlDB 通信的方式实际上是通过它的 HTTP 端点。您仍然可以将服务器嵌入到您自己的 Java 应用程序中并在本地讨论 HTTP,尽管 运行将它们放在单独的 JVM 中有很多好处。

KsqlDb 0.10 已经发布,其中的最新功能是 Java 客户端。

请通过 - https://www.confluent.io/blog/ksqldb-0-10-0-latest-features-updates/