跳到主要内容
版本:Next

示例目录

这些示例随仓库一起维护,并由 pnpm docs:check 检查。依赖服务的示例需要相应的本地服务;初次学习配置结构时请先使用 quickstart。

工作流示例适用场景
快速开始generate_example.yaml本地的从数据源到 stdout 的流水线
Kafkakafka_example.yamlKafka 输入配置
SQL 输出sql_output_example.yaml数据库 sink 配置
持久化durability_example.yaml流级 WAL 持久化
S3 持久化durability_example_s3.yaml基于对象存储的恢复
控制平面control_plane_example.yamlHub 与计算节点运维
控制平面 Hubcontrol_plane_hub.yaml集群级配置
本地流式作业jobs_local.yaml带事件时间、状态与检查点的声明式 jobs DAG
Debezium CDCcdc_debezium.yamlCDC envelope 解码

对于每个依赖服务的示例,在共享环境中运行之前请先校验凭据与端点。