Kafka Streams API

原创
無名 发表于: 2016-07-06   最后更新时间: 2021-09-26 19:55:15  
{{totalSubscript}} 订阅, 35,713 游览

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

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

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-streams</artifactId>
    <version>3.5.1</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.5.1</version>
</dependency>
更新于 2021-09-26

查看kafka更多相关的文章或提一个关于kafka的问题,也可以与我们一起分享文章