也许是一个幼稚的问题,但任何人都可以为我提供 KSQL 的 sbt 依赖项吗?
我检查了Maven,但找不到任何东西。
依赖项是否托管在 Maven 以外的其他地方,如果是,我必须在 build.sbt 文件中添加的左轮手枪是什么?
我正在尝试编写一个 Scala 应用程序,它使用 Ksql 来查询一些 kafka 主题,以创建一个带有一些指标的仪表板。
也许是一个幼稚的问题,但任何人都可以为我提供 KSQL 的 sbt 依赖项吗?
我检查了Maven,但找不到任何东西。
依赖项是否托管在 Maven 以外的其他地方,如果是,我必须在 build.sbt 文件中添加的左轮手枪是什么?
我正在尝试编写一个 Scala 应用程序,它使用 Ksql 来查询一些 kafka 主题,以创建一个带有一些指标的仪表板。
Maven Central 中没有任何 Confluent 依赖项
请参阅 https://docs.confluent.io/current/installation/clients.html#maven-repository-for-jars
我认为这是 KSQL 客户端目标
<dependency>
<groupId>io.confluent.ksql</groupId>
<artifactId>ksql-engine</artifactId>
</dependency>
示例 Java 代码 - https://github.com/confluentinc/ksql/tree/master/ksqldb-examples/src/main/java/io/confluent/ksql/embedded
不过,您不需要在代码中嵌入 KSQL。它意味着在 KSQL Server 上独立运行,您可以从代码提交或使用 KSQL CLI。在您的应用程序中,您将直接使用常规使用者或 Kafka Streams API
我也建议尝试新的 Scala Kafka Streams 包装器