Kafka Streams API

原创
無名 发表于: 2016-07-06   最后更新时间: 2020-12-24 21:26:32  
{{totalSubscript}} 订阅,30338 游览

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

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

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-streams</artifactId>
    <version>2.8.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>2.8.0</version>
</dependency>


您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容



提问