ksqldb - 如何在 SpringBoot 应用程序中使用 EmbeddedKsql？
问题描述
我已经启动并运行了 Kafka Streams java 应用程序。我试图使用 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。该项目不提供任何维护版本之间兼容性的保证。
如果您要运行嵌入在 Java 应用程序中的 ksqlDB，那么KsqlContext将是可以使用的类。但我不确定它是最新的，我也不能保证它不会在未来的版本中被删除。恐怕没有任何文档或示例可供查看，因为它不支持使用。
唯一受支持的与 ksqlDB 通信的方式实际上是通过其 HTTP 端点。您仍然可以将服务器嵌入到您自己的 Java 应用程序中并在本地使用 HTTP，尽管在单独的 JVM 中运行它们有很多好处。