Integrations

Integrations connect Datum streams to external data systems. They keep the core blueprint-vs-run contract: configuration builds a stream blueprint, and network or database work starts only when the stream is materialized.

Integration	Crate	What it covers
Kafka	datum-mq	committable Kafka sources, producer sinks, rebalance behavior, TLS/SASL, and delivery confirmation
CDC	datum-cdc	PostgreSQL logical replication, ChangeEvent, checkpoints, WAL retention, and slot lifecycle
SQL	datum-sql	DataFusion SQL over Datum streams, Arrow batches, watermarks, changelog batches, and sinks