StreamNative Connector Hub
Discover and deploy connectors to integrate StreamNative with hundreds of data sources and sinks.
What are Connectors?
StreamNative connectors enable you to easily integrate with external systems, allowing you to move data into and out of your Pulsar clusters. Connectors are available in two main categories:
- Source Connectors: Pull data from external systems into Pulsar topics
- Sink Connectors: Push data from Pulsar topics to external systems
Getting Started
Pulsar IO Overview
Learn the fundamentals of Pulsar IO connectors and how they work.
Deploy Connectors
Step-by-step guide to deploy your first connector.
Manage Connectors
Learn how to manage, update, and troubleshoot your connectors.
Monitor Connectors
Set up monitoring and troubleshooting for your connectors.
Kafka Connect
Kafka Connect Overview
Use Kafka Connect framework with StreamNative Cloud.
Deploy Kafka Connectors
Deploy and manage Kafka Connect connectors.
Available Connectors
Browse our comprehensive library of pre-built connectors for popular data sources and destinations.
Source Connectors
| 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 |
Sink Connectors
| 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 |