TypeStream - Integrations

Native TypeStream Integrations

With a growing number of out of the box solutions with a number of external systems, TypeStream makes it easy to move and transform data with a single line of code.

Sources

Databases

Stream every insert, update, and delete from your database in real time. Connect your existing database and start streaming in minutes.

Cassandra

Capture changes from Apache Cassandra using the commit log.

Db2

Stream changes from IBM Db2 for Linux, UNIX, and Windows.

Informix

Capture changes from IBM Informix using the CDC API.

Incubating

MariaDB

Capture row-level changes from MariaDB via the binlog with a dedicated connector.

MongoDB

Stream document changes from MongoDB using change streams. Supports replica sets and sharded clusters.

MySQL

Capture row-level changes from MySQL via the binlog.

Oracle

Stream changes from Oracle Database using LogMiner or XStream.

PostgreSQL

Stream changes from PostgreSQL using logical replication. Supports all Postgres-compatible databases.

Spanner

Stream changes from Google Cloud Spanner, the globally distributed relational database.

SQL Server

Capture changes from Microsoft SQL Server using its native CDC feature.

Vitess

Capture changes from Vitess, the MySQL-compatible distributed database used by PlanetScale.

Incubating

Sinks

Databases

Write pipeline output directly to relational, document, graph, and key-value databases via Kafka Connect sink connectors.

Amazon DynamoDB

Export streaming data to DynamoDB for serverless NoSQL workloads at any scale.

Azure Cosmos DB

Sink data into Azure Cosmos DB for globally distributed, multi-model database workloads.

Cassandra

Sink data into Apache Cassandra for distributed, high-throughput writes.

MongoDB

Write pipeline output to MongoDB collections for document-based workloads.

MySQL (JDBC)

Sink pipeline results into MySQL or MariaDB via the JDBC sink connector.

Neo4j

Sink streaming data into Neo4j for graph-based analytics and relationship discovery.

PostgreSQL (JDBC)

Write transformed data back to PostgreSQL or any JDBC-compatible database.

Redis

Push streaming results into Redis for low-latency caching and key-value lookups.

Sinks

Data Warehouses & Analytics

Stream data into warehouses and OLAP engines for real-time analytics, reporting, and business intelligence.

Amazon Redshift

Export streaming data to Amazon Redshift for cloud data warehouse analytics.

Apache Druid

Ingest streaming data into Druid for sub-second OLAP queries and real-time analytics.

Native Kafka Ingestion

Pi

Apache Pinot

Feed data into Pinot for user-facing real-time analytics at scale.

Native Kafka Ingestion

ClickHouse

Sink data into ClickHouse for real-time OLAP queries on streaming data.

Databricks Delta Lake

Sink streaming data into Databricks Delta Lake for unified analytics and ML workloads.

Google BigQuery

Stream data directly into BigQuery for warehouse analytics and reporting.

Snowflake

Load streaming data into Snowflake for cloud data warehousing and analytics.

Sinks

Search

Index streaming data into search engines for full-text search, log analytics, and security workloads.

Elasticsearch

Index streaming data into Elasticsearch for full-text search and analytics.

OpenSearch

Sink data into OpenSearch for search, observability, and security analytics.

Sinks

Object & File Storage

Write streaming data to cloud object stores and distributed file systems for data lake, archival, and batch processing workloads.

Amazon S3

Write streaming data to S3 in Parquet, Avro, or JSON for data lake and archival workloads.

Azure Blob Storage

Write streaming data to Azure Blob Storage for cloud-native data lake workloads.

Google Cloud Storage

Sink data to GCS buckets in Parquet, Avro, or JSON format.

HDFS 3

Write to Hadoop Distributed File System for big data batch processing pipelines.

Sources & Sinks

Observability

Ingest traces, metrics, and logs into Kafka and route them to observability platforms for monitoring, alerting, and performance analysis.

Datadog

Route logs and events to Datadog for monitoring, alerting, and observability dashboards.

InfluxDB

Write time-series data into InfluxDB for monitoring and IoT workloads.

OpenTelemetry

Ingest OTLP traces, metrics, and logs into Kafka topics for observability pipelines.

New Relic

Stream events and logs to New Relic for full-stack observability and performance monitoring.

Splunk

Route events to Splunk for security information and event management.

Sinks

Messaging & Streaming

Forward events to other messaging systems and streaming platforms for cross-cloud and hybrid architectures.

Ki

Amazon Kinesis

Forward streaming data to Kinesis Data Streams for AWS-native pipelines.

Community Connector

Google Pub/Sub

Publish events to Google Cloud Pub/Sub for GCP-native messaging workflows.

Community Connector

MQTT

Publish events to MQTT brokers for IoT and edge computing workloads.

RabbitMQ

Forward streaming data to RabbitMQ for message queue and routing workloads.

Sinks

AI & Vector

Push streaming data into vector databases for similarity search, RAG pipelines, and AI/ML embedding workloads.

Google Cloud Bigtable

Sink data into Cloud Bigtable for wide-column NoSQL workloads at petabyte scale.

Milvus

Sink streaming data into Milvus for vector search and AI/ML embedding workloads.

Qdrant

Push streaming data into Qdrant for vector similarity search and RAG pipelines.

Sinks

General

Send streaming data to any HTTP endpoint or webhook for custom integrations and general-purpose connectivity.

Ht

HTTP / REST

POST events to any HTTP endpoint or webhook for custom integrations.