我已经启动并运行了 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 0.10 已经发布，其中最新的功能是 Java 客户端。
请通过-https://www.confluent.io/blog/ksqldb-0-10-0-latest-features-updates/
【讨论】：
KsqlDB 服务器目前没有受支持的 Java API。该项目不提供任何维护版本之间兼容性的保证。
如果您要在 Java 应用程序中运行嵌入的 ksqlDB，那么 KsqlContext 将是可以使用的类。但我不确定它是最新的，我也不能保证它不会在未来的版本中被删除。恐怕没有任何文档或示例可供查看，因为它不支持使用。
唯一受支持的与 ksqlDB 通信的方式实际上是通过其 HTTP 端点。您仍然可以将服务器嵌入到您自己的 Java 应用程序中并在本地使用 HTTP，尽管在单独的 JVM 中运行它们有很多好处。
【讨论】：