Connectors

A growing connector library. Four available today - build the rest in Go or Rust.

Postgres, SQL Server, Kafka, and files stream today, with column mapping and lag monitoring. Dozens more connectors are on the roadmap - or build your own with the open SDK.

No connectors match your search. Request one →

Open connector SDK

Build your own connector

Zipline's connector SDK is fully open. Write a source or sink in Go or Rust and deploy it alongside official connectors - same effectively-once-for-idempotent-sinks guarantees, same observability hooks, same Terraform resource.

Go SDK

Write a source in Go

go get zipline.run/sdk-go // implement the source read style: func (s *Source) Read(ctx context.Context) (zip.Batch, error) func (s *Source) Ack(ctx context.Context, durable zip.Position) error
Read Go docs
Rust SDK

Write a sink in Rust

cargo add zipline-sdk // implement the Sink trait: async fn write( &mut self, batch: Vec<Event>, ) -> Result<()> { ... }
Read Rust docs

Start streaming in 30 seconds

Pick a source. Pick a sink. Zipline handles the rest.

Start free trial View on GitHub