kafka-streams-topology - 设计 Kafka Streams 流处理拓扑
提供 Kafka Streams 抽象、拓扑模式、流操作、连接、窗口、状态存储和恰好一次语义方面的指导。
标签
更新于: 2026-09-29能力
典型输入
典型输出
该技能可以做什么
- 设计流处理拓扑
- 比较 KStream 和 KTable
- 应用流转换操作
- 按条件路由事件
- 连接流与表
- 配置窗口策略
- 管理状态存储
- 解释恰好一次语义
- 优化流处理
输入
- 拓扑设计需求
- Kafka 流数据模型
- 连接需求
- 窗口需求
- 处理语义需求
输出
- 拓扑设计指导
- Kafka Streams 代码示例
- 流处理建议
- 连接配置指导
- 窗口配置指导
要求
- Java 或 Kotlin 环境
- Kafka Streams 库
- 支持 Kafka Streams 的模型能力