Integrations

Plug in anything that emits events.

Connect your queues, databases and SaaS tools in a few clicks. Send typed tables on to your warehouse, dashboards and models without writing glue code.

Catalog

64 integrations

Early access

12 in beta

Typical setup

2-minute setup

Catalog

In, out and everywhere between.

All Sources Destinations BI & notebooks AI & ML

Corvid AI

Give Corvid live, row-level context through a typed tool.

Vastquery

Write views through the Storage Write API, partitioned by time.

Edgeline Workers

Query the nearest Basalt region from any Worker.

Panelo

Live panels over the Postgres wire protocol, no plugin needed.

Hexel

Query views from SQL cells and keep notebooks current.

Iceberg

Commit views to Apache Iceberg tables with snapshot isolation.

Kafka

Read any topic with consumer-group offsets and exactly-once commits.

Nimbia

Embed events as they land and store vectors beside the rows.

Postgres CDC

Logical replication from the WAL, with snapshots and schema changes.

Trackline

Forward track, identify and page calls as typed events.

Frostbase

Sync any view to a table with Frostpipe Streaming.

Paylane webhooks

Signed payment, invoice and subscription events, deduplicated.

Coldvault

Land Parquet files by hour or by size, with a manifest per batch.

Watchly

Ship lag, throughput and p99 metrics per source and view.

Craft

Run Craft models as incremental Basalt views, tests included.

Jupyter

Load any table into a DataFrame with the Python SDK.

Streamtide

Stream shards from AWS with enhanced fan-out and checkpointing.

Chainweave

A retriever and a tool that read Basalt tables directly.

Plotbase

Point a Postgres connection at Basalt and build questions live.

Docudb

Change streams from replica sets and Atlas clusters.

MySQL CDC

Binlog capture for MySQL 8 and Aurora, row-level and ordered.

Pinevale

Upsert embeddings from a view and keep the index in sync.

Redwren

Kafka-compatible ingest with the same offsets and ordering guarantees.

Driftcloud

Read tables from Edge Functions with one environment variable.

64 in the catalog · 24 shown here

Connector SDK

Build your own in an afternoon.

The connector SDK is open source under Apache 2.0. Describe the schema, yield events, and Basalt handles checkpoints, retries, back-pressure and exactly-once delivery for you.

Read the SDK guide

sources/inventory.ts

import { defineSource, t } from "@basalt/connector-sdk";

export default defineSource({
  name: "warehouse-inventory",
  schema: {
    sku: t.string(),
    on_hand: t.int(),
    updated_at: t.timestamp(),
  },
  // Basalt stores the cursor and resumes after restarts
  async *poll({ cursor }) {
    const rows = await api.changesSince(cursor ?? 0);
    for (const row of rows) yield { key: row.sku, value: row };
  },
  every: "5s",
});

✓ schema registered · warehouse-inventory v1

✓ first checkpoint committed in 41 ms

✓ source live in eu-north-1

Missing a source?

Tell us what you run. We ship new connectors every two weeks, and requests with the most votes go first.

Request an integration

Get started

Set your data in stone.

Free up to 10M events a month. No card, no sales call. Your first pipeline is live in about four minutes.

Project reserved · check your inbox

That didn't go through · check the address and try again

2,400+ teams in productionSOC 2 Type II38 regions