Stream into SingleStore Dekaf with your free account

The SingleStore (Dekaf) connector streams Flow collections as Kafka-compatible messages that can be consumed directly by SingleStore pipelines. It enables real-time data ingestion from Estuary into SingleStore’s distributed SQL engine for hybrid transactional and analytical workloads.

• Real-time delivery: Streams collection updates to SingleStore pipelines over Kafka in Avro format.
• High-performance integration: Leverages SingleStore’s native ingestion pipeline for low-latency, scalable data flow.
• Simple authentication: Uses a configurable auth token as both the Kafka and Schema Registry credential.
• Flexible configuration: Each Flow collection is published as a separate Kafka topic for easy mapping.
• Deletion handling: Supports both standard Kafka-style deletes and CDC deletion modes for downstream processing.
• Quick setup: Define a pipeline in SingleStore with the LOAD DATA KAFKA command and start ingesting immediately.

💡 Tip: Use ReplacingMergeTree or similar table engines in SingleStore when handling CDC deletions to maintain accurate, up-to-date data states across real-time pipelines.