付费隐藏内容

在0.10.0增加了一个新的客户端库,Kafka Stream

可以使用maven引入到你的项目中:

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-streams</artifactId>
    <version>3.7.0</version>
</dependency>

如何使用,请点击这里。(注意,@InterfaceStability.Unstable注解的类,是公共API,在未来可能改变,不保证向后兼容)

当使用Scala时,你可以选择包含kafka-streams-scala库。关于使用Scala的Kafka Streams DSL的其他文档可在开发者指南中找到。

要使用基于Scala 2.13的Kafka Streams DSL,可以使用以下maven依赖:

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-streams-scala_2.13</artifactId>
    <version>3.7.0</version>
</dependency>

+
652字
提交中,请稍后!