示例目录
这些示例随仓库一起维护,并由 pnpm docs:check 检查。依赖服务的示例需要相应的本地服务;初次学习配置结构时请先使用 quickstart。
| 工作流 | 示例 | 适用场景 |
|---|---|---|
| 快速开始 | generate_example.yaml | 本地的从数据源到 stdout 的流水线 |
| Kafka | kafka_example.yaml | Kafka 输入配置 |
| SQL 输出 | sql_output_example.yaml | 数据库 sink 配置 |
| 持久化 | durability_example.yaml | 流级 WAL 持久化 |
| S3 持久化 | durability_example_s3.yaml | 基于对象存储的恢复 |
| 控制平面 | control_plane_example.yaml | Hub 与计算节点运维 |
| 控制平面 Hub | control_plane_hub.yaml | 集群级配置 |
| 本地流式作业 | jobs_local.yaml | 带事件时间、状态与检查点的声明式 jobs DAG |
| Debezium CDC | cdc_debezium.yaml | CDC envelope 解码 |
对于每个依赖服务的示例,在共享环境中运行之前请先校验凭据与端点。