Kafka Streams API

在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>