官方原文地址:https://kafka.apache.org/0101/documentation.html#streamsapi
Streams API 允許將輸入 topic 的數(shù)據(jù)流轉(zhuǎn)換為輸出 topic 的數(shù)據(jù)流。
如何使用類庫(kù)的示例在 javadoc 中癞志。
更多關(guān)于 Streams API 的文檔在這里。
使用 Streams贪染,需要添加下面的 maven 依賴:
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka-streams</artifactId>
<version>0.10.1.0</version>
</dependency>