Connector SDK v2 ships today. If you wrote a v1 source, migration is mechanical — a one-day task for most sources.
import { defineSource } from "@dxdata/sdk";
export default defineSource({
name: "postgres",
async discover({ config }) { /* ... */ },
async snapshot({ table, since }) { /* ... */ },
async stream({ table, cursor }) { /* ... */ },
});What changed
The biggest change is that the SDK now owns backpressure, retry, and checkpointing. You describe the three lifecycle hooks; the SDK runs them. This removed the majority of custom error-handling code from every source we have seen in the wild.
Written by
Noah Abrams
Open Source Lead at DXData.