官方原文地址:https://kafka.apache.org/0101/documentation.html#streamsapi
Streams API 允许将输入 topic 的数据流转换为输出 topic 的数据流。
如何使用类库的示例在 javadoc 中。
更多关于 Streams API 的文档在这里。
使用 Streams,需要添加下面的 maven 依赖:
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams</artifactId>
<version>0.10.1.0</version>
</dependency>