Streaming Connectors

CrateDB integrates natively with Apache Kafka, the industry standard for event streaming. You can stream millions of events per second from Kafka topics directly into CrateDB, where data becomes instantly searchable and analyzable.

Key benefits:

• High-throughput ingestion from Kafka topics
• Low-latency writes with automatic distribution
• Perfect for IoT, observability, and log analytics use cases

CrateDB works seamlessly with Apache Flink, enabling advanced stream processing and analytics before data lands in the database. Together, Flink and CrateDB create a powerful real-time pipeline. Flink processes and enriches events, while CrateDB stores and indexes them for sub-second querying.

CrateDB works seamlessly with Apache Flink, enabling advanced stream processing and analytics before data lands in the database.
Together, Flink and CrateDB create a powerful real-time pipeline — Flink processes and enriches events, while CrateDB stores and indexes them for sub-second querying.

Common patterns:

• Use Flink for transformations and windowed aggregations
• Store processed results in CrateDB for dashboards and AI models
• Query enriched data using standard SQL in milliseconds

CrateDB supports Change Data Capture (CDC) pipelines to keep your analytical layer in sync with operational databases.
Using connectors like Debezium, CrateDB continuously ingests inserts, updates, and deletes,  eliminating the need for batch synchronization or ETL jobs.

Why CDC matters:

• Keep analytics continuously updated
• Reduce latency between operational and analytical systems
• Simplify architecture with real-time sync

For IoT and edge deployments, CrateDB supports lightweight MQTT protocols, enabling millions of connected devices to stream telemetry data efficiently.
Combined with edge-friendly deployment options, this makes CrateDB ideal for industrial and sensor-based environments.

Use cases:

• Real-time factory and sensor monitoring
• Smart mobility and connected vehicles
• Edge-to-cloud data integration

CrateDB’s native HTTP endpoint provides a simple, flexible way to ingest data from custom applications, services, and microservices. This allows easy integration with any modern data producer, from web apps to serverless backends.

Highlights:

• JSON over HTTP for easy data pushes
• Works with any programming language
• Ideal for microservices architectures

Whether it’s Kafka, Flink, MQTT, CDC, or HTTP, CrateDB unifies all incoming streams into a single, real-time database.
You get one place to store, query, and analyze data from everywhere, instantly and at scale.