Discover and deploy connectors to integrate StreamNative with hundreds of data sources and sinks.
Connector | Type | Description | Documentation |
---|---|---|---|
ActiveMQ | Message Queue | Integrate with Apache ActiveMQ message broker | 📖 Docs |
AMQP 1.0 | Message Queue | Connect to AMQP 1.0 compatible message brokers | 📖 Docs |
Canal | Database CDC | MySQL binlog change data capture using Alibaba Canal | 📖 Docs |
Debezium MongoDB | Database CDC | MongoDB change data capture using Debezium | 📖 Docs |
Debezium SQL Server | Database CDC | SQL Server change data capture using Debezium | 📖 Docs |
Debezium MySQL | Database CDC | MySQL change data capture using Debezium | 📖 Docs |
Debezium PostgreSQL | Database CDC | PostgreSQL change data capture using Debezium | 📖 Docs |
File | File System | Read data from local or remote files | 📖 Docs |
Flume | Data Collection | Integrate with Apache Flume data collection service | 📖 Docs |
Google BigQuery | Analytics | Read data from Google BigQuery tables | 📖 Docs |
Google Pub/Sub | Message Queue | Consume messages from Google Cloud Pub/Sub | 📖 Docs |
Kafka Connect JR | Testing | Generate test data with JSON Schema Registry | 📖 Docs |
Kafka Connect MongoDB | Database | MongoDB source connector via Kafka Connect | 📖 Docs |
YugabyteDB CDC | Database CDC | YugabyteDB change data capture | 📖 Docs |
Kafka | Message Queue | Pull data from Apache Kafka topics | 📖 Docs |
Kinesis | Stream Processing | Amazon Kinesis data streams integration | 📖 Docs |
Lakehouse | Data Lake | Read from lakehouse storage systems | 📖 Docs |
Netty | Network | TCP/UDP network data ingestion | 📖 Docs |
RabbitMQ | Message Queue | Consume from RabbitMQ message broker | 📖 Docs |
Amazon SQS | Message Queue | Amazon Simple Queue Service integration | 📖 Docs |
Twitter Firehose | Social Media | Real-time Twitter data streaming | 📖 Docs |
Connector | Type | Description | Documentation |
---|---|---|---|
ActiveMQ | Message Queue | Send data to Apache ActiveMQ message broker | 📖 Docs |
Aerospike | Database | High-performance NoSQL database integration | 📖 Docs |
AMQP 1.0 | Message Queue | Send to AMQP 1.0 compatible message brokers | 📖 Docs |
AWS EventBridge | Event Processing | Amazon EventBridge event bus integration | 📖 Docs |
AWS Lambda | Serverless | Trigger AWS Lambda functions | 📖 Docs |
Amazon S3 | Object Storage | Store data in Amazon S3 buckets | 📖 Docs |
Azure Blob Storage | Object Storage | Microsoft Azure blob storage integration | 📖 Docs |
Cassandra | Database | Apache Cassandra distributed database | 📖 Docs |
Elasticsearch | Search Engine | Elasticsearch full-text search and analytics | 📖 Docs |
Flume | Data Collection | Send data to Apache Flume | 📖 Docs |
Google BigQuery | Analytics | Load data into Google BigQuery | 📖 Docs |
Google Cloud Storage | Object Storage | Store files in Google Cloud Storage | 📖 Docs |
Google Pub/Sub | Message Queue | Publish to Google Cloud Pub/Sub | 📖 Docs |
HBase | Database | Apache HBase distributed database | 📖 Docs |
HDFS3 | File System | Hadoop Distributed File System v3 | 📖 Docs |
InfluxDB | Time Series | Time series database for metrics and events | 📖 Docs |
JDBC ClickHouse | Analytics | ClickHouse columnar database via JDBC | 📖 Docs |
JDBC MariaDB | Database | MariaDB relational database via JDBC | 📖 Docs |
JDBC PostgreSQL | Database | PostgreSQL relational database via JDBC | 📖 Docs |
JDBC SQLite | Database | SQLite embedded database via JDBC | 📖 Docs |
Kafka Connect BigQuery | Analytics | BigQuery integration via Kafka Connect | 📖 Docs |
Kafka Connect DataGen | Testing | Generate test data for development | 📖 Docs |
Kafka Connect Elasticsearch | Search Engine | Elasticsearch via Kafka Connect framework | 📖 Docs |
Kafka Connect Iceberg | Data Lake | Apache Iceberg table format integration | 📖 Docs |
Kafka Connect Milvus | Vector Database | Milvus vector database for AI/ML workloads | 📖 Docs |
Kafka Connect MongoDB | Database | MongoDB via Kafka Connect framework | 📖 Docs |
Kafka Connect Snowflake | Data Warehouse | Snowflake cloud data warehouse | 📖 Docs |
Kafka | Message Queue | Send data to Apache Kafka topics | 📖 Docs |
Kinesis | Stream Processing | Amazon Kinesis data streams | 📖 Docs |
Lakehouse | Data Lake | Write to lakehouse storage systems | 📖 Docs |
MongoDB | Database | MongoDB document database | 📖 Docs |
Pinecone | Vector Database | Pinecone vector database for ML applications | 📖 Docs |
RabbitMQ | Message Queue | Send to RabbitMQ message broker | 📖 Docs |
Redis | Cache | Redis in-memory data structure store | 📖 Docs |
Snowflake | Data Warehouse | Snowflake cloud data platform | 📖 Docs |
Snowflake Streaming | Data Warehouse | Snowflake real-time data ingestion | 📖 Docs |
Solr | Search Engine | Apache Solr search platform | 📖 Docs |
Amazon SQS | Message Queue | Amazon Simple Queue Service | 📖 Docs |