面向分布式生产系统的数据集成底座，具备容错、模式演进与多引擎执行能力，覆盖批处理、流处理、CDC、多模态与 AI 数据场景。
架构模式
SeaTunnel 负责抽取、轻量转换与装载，把重量级的下游转换保留给仓库或湖仓，让数据链路更清晰也更稳定。
为什么选择 SeaTunnel
容错、模式演进和多引擎扩展能力都按分布式生产环境要求设计。
SeaTunnel 能检测上游 Schema 变化并实时同步到下游，减少因为字段变更带来的人工迁移与任务中断。
# Before -> After (detected automatically) -- v1 schema ------------------------- id BIGINT name VARCHAR(255) -- v2 schema (auto-propagated) ------ id BIGINT name VARCHAR(255) email VARCHAR(512) NEW phone VARCHAR(32) ADDED
面向主流数据库的低延迟变更捕获，同时支持从批到流无缝衔接，并避免锁式切换。
基于 checkpoint 的容错保证任务在失败、重试与重启场景下仍保持数据一致性。
同一份 pipeline 定义可运行在 Zeta、Flink 或 Spark 上，无需重写连接器逻辑与交付链路。
约 200 个原生连接器
覆盖数据库、消息系统、湖仓、搜索系统与对象存储等主流数据系统。
# Real-time: MySQL CDC -> ClickHouse
env {
parallelism = 4
job.mode = "STREAMING"
checkpoint.interval = 10000
}
source {
MySQL-CDC {
hostname = "db.prod.internal"
username = "reader"
password = "${DB_PASS}"
database-names = ["orders"]
table-names = ["orders.events"]
base-url = "jdbc:mysql://db.prod.internal:3306"
}
}
transform {
Sql {
query = """
SELECT *, NOW() AS synced_at
FROM events WHERE status != 'deleted'
"""
}
}
sink {
ClickHouse {
host = "ch.analytics:8123"
database = "analytics"
table = events_realtime
primary_key = ["id"]
}
}