| 形态 | 库（嵌入应用），不是独立计算集群 |
|---|---|
| 抽象 | KStream（事件流）、KTable（变更表）、GlobalKTable |
| 容错 | 本地状态 + changelog 主题重建 |
| 语义 | processing.guarantee=exactly_once_v2 支持端到端精确一次 |
统计示例（Java 片段）
统计示例（Java 片段）
StreamsBuilder builder = new StreamsBuilder();
KStream<String, String> orders = builder.stream("orders");
orders.groupByKey()
.count()
.toStream()
.to("order-counts");Kafka Streams 适合 Kafka 内闭环的轻量流处理；要连接外部系统或复杂事件时间语义时，Flink 等引擎更常见。