StreamNative Connector Hub

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
DynamoDB	Database	Read data from AWS DynamoDB	📖 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 Debezium MongoDB	Database CDC	Debezium MongoDB source connector via Kafka Connect	📖 Docs
Kafka Connect Debezium Mysql	Database CDC	Debezium Mysql source connector via Kafka Connect	📖 Docs
Kafka Connect Debezium PostgreSql	Database CDC	Debezium PostgreSql source connector via Kafka Connect	📖 Docs
Kafka Connect Debezium Spanner	Database CDC	Debezium Cloud Spanner source connector via Kafka Connect	📖 Docs
Kafka Connect Debezium SqlServer	Database CDC	Debezium Sql Server source connector via Kafka Connect	📖 Docs
Kafka Connect Cosmos DB	Database	Read data from Azure Cosmos DB change feed via Kafka Connect	📖 Docs
Kafka Connect JDBC	Database	Reads data from any JDBC-compliant database and writes data to Kafka topics	📖 Docs
Kafka Connect JR	Testing	Generate test data with JSON Schema Registry	📖 Docs
Kafka Connect MongoDB	Database	MongoDB source connector via Kafka Connect	📖 Docs
Kafka Connect Google Pub/Sub	Message Queue	Persists data from Google Cloud Pub/Sub into Apache Kafka topic via Kafka Connect	📖 Docs
Kafka Connect Google Pub/Sub Lite	Message Queue	Persists data from Google Cloud Pub/Sub Lite into Apache Kafka topic 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 Cosmos DB	Database	Write data to Azure Cosmos DB via Kafka Connect	📖 Docs
Kafka Connect DataGen	Testing	Generate test data for development	📖 Docs
Kafka Connect Debezium JDBC	Database	Write events to a relational database by using a JDBC driver.	📖 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 JDBC	Database	Writes data to any JDBC-compliant database	📖 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 Connect Google Pub/Sub	Message Queue	Persists data from Apache Kafka topics as a data sink into Google Cloud Pub/Sub via Kafka Connect	📖 Docs
Kafka Connect Google Pub/Sub Lite	Message Queue	Persists data from Apache Kafka topics as a data sink into Google Cloud Pub/Sub via Kafka Connect	📖 Docs
Kafka Connect Google Cloud Storage	Object Storage	Writes data from Kafka topics to a GCS(Google Cloud Storage) bucket	📖 Docs
Kafka Connect Google Bigtable	Database	Stream data from Kafka topics into Bigtable in real time	📖 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

What’s Next?

Deploy Your First Connector

Follow our step-by-step guide to deploy your first connector.

Configuration Reference

Learn about connector configuration options and best practices.

Monitor & Troubleshoot

Set up monitoring and troubleshooting for your connectors.

Sources

Sinks

What are Connectors?

Getting Started

Pulsar IO Overview

Deploy Connectors

Manage Connectors

Monitor Connectors

Kafka Connect

Kafka Connect Overview

Deploy Kafka Connectors

Available Connectors

Source Connectors

Sink Connectors

What’s Next?

Deploy Your First Connector

Configuration Reference

Monitor & Troubleshoot

​What are Connectors?

​Getting Started

Pulsar IO Overview

Deploy Connectors

Manage Connectors

Monitor Connectors

​Kafka Connect

Kafka Connect Overview

Deploy Kafka Connectors

​Available Connectors

​Source Connectors

​Sink Connectors

​What’s Next?

Deploy Your First Connector

Configuration Reference

Monitor & Troubleshoot

What are Connectors?

Getting Started

Kafka Connect

Available Connectors

Source Connectors

Sink Connectors

What’s Next?