Connect about 200 sources and sinks with a single config file. Run on Flink, Spark, or the native Zeta engine for batch and streaming workloads.
Architecture
SeaTunnel handles extract, lightweight transform, and load. Your warehouse or lakehouse can keep the heavy downstream transformation while SeaTunnel moves reliable, structured data between systems.
Why SeaTunnel
Real fault tolerance, schema evolution, and multi-engine scale for production pipelines.
SeaTunnel detects upstream schema changes and propagates them downstream in real time, so teams do not need to pause the pipeline for every column change.
# 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
Capture INSERT, UPDATE, and DELETE events from MySQL, Oracle, PostgreSQL, SQL Server, MongoDB, and more with low latency.
Checkpoint-backed fault tolerance keeps records consistent across failures, retries, and restarts.
Write one pipeline definition and run it on Zeta, Flink, or Spark without rewriting connector logic.
~200 Native Connectors
Native connectors across databases, streams, lakehouses, search systems, and object stores.
How it works
One config file defines the full EtLT pipeline, from ingestion through lightweight transformation and delivery.
Simple by design
Declare your source, transform, and sink in plain config, then deploy on any supported engine without rewriting the pipeline.
⭐️
# 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"]
}
}Open source. Apache licensed. Free forever. Built for production teams that need a reliable integration layer instead of another fragile demo.