olake

OLake Go

OLake Go is a high-performance, open-source data ingestion engine for replicating databases, S3, and Kafka into Apache Iceberg (or plain Parquet).
Built for scalable, real-time pipelines, OLake Go provides a simple web UI and CLI - used to ingest into vendor-lock-in free Iceberg tables supporting all the query-engines/warehouses.

Read the docs and benchmarks at olake.io/docs. Join our active community on Slack.

[!NOTE] 🎉 OLake Fusion is now live! — Automate your Apache Iceberg Table Maintenance. Check it out here → github.com/datazip-inc/olake-fusion 🎉

OLake Go — Super-fast Sync to Apache Iceberg

OLake Go supports replication from transactional databases such as PostgreSQL, MySQL, MongoDB, Oracle, DB2, and MSSQL, event-streaming systems like Apache Kafka and Object-store like S3, into open data lakehouse formats such as Apache Iceberg or Plain Parquet — delivering blazing-fast performance with minimal infrastructure cost.

🚀 Why OLake Go?

• 🧠 Smart sync: Full + CDC replication with automatic schema discovery & schema evolution
• ⚡ High throughput: 580K RPS (Postgres) & 338K RPS (MySQL)
• ➡️ Exactly once delivery & Arrow writes: Accuracy with speed.
• 💾 Iceberg-native: Supports Glue, Hive, JDBC, REST catalogs
• 🖥️ Self-serve UI: Deploy via Docker Compose and sync in minutes
• 💸 Infra-light: No Spark, no Flink, no Kafka, no Debezium

📊 Benchmarks

Full Load

CDC

🔧 Supported Sources and Destinations

Sources (Databases)

Source (S3)

Source (Kafka)

Destinations

Writer Docs

1. Apache Iceberg Docs

   1. Catalogs
      1. AWS Glue Catalog
      2. REST Catalog
         • Generic
         • Lakekeeper
         • Nessie
         • S3 Tables
         • Unity
         • Apache Polaris
      3. JDBC Catalog
      4. Hive Catalog
   2. Azure ADLS Gen2
   3. Google Cloud Storage (GCS)
   4. MinIO (local)

2. Parquet Writer

   1. AWS S3 Docs
   2. Google Cloud Storage (GCS)
   3. Local FileSystem Docs

🧪 Quickstart (UI + Docker)

OLake UI is a web-based interface for managing OLake Go jobs, sources, destinations and configurations. You can run the entire OLake Go stack (UI, Backend, and all dependencies) using Docker Compose. This is the recommended way to get started. Run the UI, connect your source DB, and start syncing in minutes.

curl -sSL https://raw.githubusercontent.com/datazip-inc/olake-ui/master/docker-compose.yml | docker compose -f - up -d

Access the UI:

• OLake UI: http://localhost:8000
• Log in with default credentials: admin / password

Detailed getting started using OLake UI can be found here.

Creating Your First Job

With the UI running, you can create a data pipeline in a few steps:

1. Configure Source: Navigate to Source tab and click Create Source. Set up your source connection.
2. Configure Destination: Navigate to Destination tab and click Create Destination. Set up your destination.
3. Create a Job: Navigate to the Jobs tab and click Create Job.
4. Configure & Run: Give your job a name, set a schedule, select your source and destination and click Next to finish.
5. Select Streams: Choose which tables to sync and configure their sync mode (CDC, Full Refresh or Incremental).

For a detailed walkthrough, refer to the Jobs documentation.

🛠️ CLI Usage (Advanced)

For advanced users and automation, OLake Go's core logic is exposed via a powerful CLI. The core framework handles state management, configuration validation, logging, and type detection. It interacts with drivers using four main commands:

• spec: Returns a render-able JSON Schema for a connector's configuration.
• check: Validates connection configurations for sources and destinations.
• discover: Returns all available streams (e.g., tables) and their schemas from a source.
• sync: Executes the data replication job, extracting from the source and writing to the destination.
• clear-destination : Clears data in the destination, only for the selected streams defined in streams.json.

Find out more about CLI here.

Install OLake Go

Below are other different ways you can run OLake Go:

1. OLake Go UI (Recommended)
2. Kubernetes using Helm
3. Standalone Docker container
4. Airflow on EC2
5. Airflow on Kubernetes

Playground

1. OLake Go + Apache Iceberg + REST Catalog + Presto
2. OLake Go + Apache Iceberg + AWS Glue + Trino
3. OLake Go + Apache Iceberg + AWS Glue + Athena
4. OLake Go + Apache Iceberg + AWS Glue + Snowflake
5. OLake Go + Apache Iceberg + REST Catalog + Spark

🌍 Use Cases

• ✅ Migrate from OLTP to Iceberg without Spark or Flink
• ✅ Enable BI over fresh CDC data using Athena, StarRocks, Trino, Presto, Dremio, Databricks, Snowflake and more!
• ✅ Build near real-time data lake-house on cost-efficient cloud object stores
• ✅ Move away from vendor-lock-in warehouse or tools with open data lake-house
• ✅ Single copy for both analytics & machine learning

🧭 Roadmap Highlights

• Oracle Full Load Support
• Oracle Incremental
• Filters for Full Load and Incremental
• Interoperability (Coming Soon)
• Iceberg V3 Support

🤝 Contributing

We ❤️ contributions, big or small!

Check out our Bounty Program. A huge thanks to all our amazing contributors!

• To contribute to the OLake Go, see CONTRIBUTING.md.
• To contribute to the UI, visit the OLake UI Repository.
• To contribute to the OLake Helm, visit the OLake Helm Repository.
• To contribute to our website and documentation, visit the Olake Docs Repository.