StreamNative Hub

Sink Connector
ActiveMQ Sink
ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ.
Authored by
StreamNative
Sink Connector
ActiveMQ sink connector
ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ.
Authored by
StreamNative
Source Connector
ActiveMQ source connector
ActiveMQ Connector integrates Apache Pulsar with Apache ActiveMQ.
Authored by
StreamNative
Sink Connector
Aerospike Sink
The Aerospike sink connector pulls messages from Pulsar topics to Aerospike clusters
Authored by
Apache Software Foundation
Sink Connector
AMQP 1.0 Sink Connector
support sink/source for AMQP version 1.0.0
Available on
StreamNative Cloud
Authored by
StreamNative
Source Connector
AMQP 1.0 Source Connector
support sink/source for AMQP version 1.0.0
Available on
StreamNative Cloud
Authored by
StreamNative
Protocol Handler
AoP
AoP brings the native AMQP protocol support to Pulsar by introducing an AMQP protocol handler on Pulsar brokers.
Authored by
StreamNative
Sink Connector
AWS EventBridge Sink Connector
Available on
StreamNative Cloud
Authored by
StreamNative
Sink Connector
AWS Lambda Sink
Available on
StreamNative Cloud
Authored by
StreamNative
Offloader
AWS S3 offloader
Use AWS S3 offloader with Pulsar
Authored by
Apache Software Foundation
Sink Connector
AWS S3 Sink Connector
Cloud Storage Connector integrates Apache Pulsar with cloud storage.
Available on
StreamNative Cloud
Authored by
StreamNative
Sink Connector
AWS SQS Sink Connector
Available on
StreamNative Cloud
Authored by
StreamNative
Source Connector
AWS SQS Source Connector
Available on
StreamNative Cloud
Authored by
StreamNative
Sink Connector
Azure Blob Storage Sink Connector
Cloud Storage Connector integrates Apache Pulsar with cloud storage.
Available on
StreamNative Cloud
Authored by
StreamNative
Source Connector
Canal Source
The Canal source connector pulls messages from MySQL to Pulsar topics.
Authored by
Apache Software Foundation
Sink Connector
Cassandra Sink
The Cassandra sink connector pulls messages from Pulsar topics to Cassandra clusters
Authored by
Apache Software Foundation
Sink Connector
Cloud Storage Sink Connector
Cloud Storage Connector integrates Apache Pulsar with cloud storage.
Available on
StreamNative Cloud
Authored by
StreamNative
Source Connector
Debezium Microsoft SQL Server Source
The Debezium Microsoft SQL Server source connector pulls messages from SQL Server and persists the messages to Pulsar topics
Available on
StreamNative Cloud
Authored by
Apache Software Foundation
Source Connector
Debezium MongoDB Source
The Debezium MongoDB source connector pulls messages from MongoDB and persists the messages to Pulsar topics
Available on
StreamNative Cloud
Authored by
Apache Software Foundation
Source Connector
Debezium MySQL Source
The Debezium source connector pulls messages from MySQL and persists the messages to Pulsar topics.
Available on
StreamNative Cloud
Authored by
Apache Software Foundation
Source Connector
Debezium PostgreSQL Source
The Debezium source connector pulls messages from PostgreSQL and persists the messages to Pulsar topics.
Available on
StreamNative Cloud
Authored by
Apache Software Foundation
Sink Connector
Elasticsearch Sink Connector
The Elasticsearch sink connector pulls messages from Pulsar topics and persists the messages to indexes
Available on
StreamNative Cloud
Authored by
Apache Software Foundation
Source Connector
File Source
The File source connector pulls messages from files in directories and persists the messages to Pulsar topics.
Authored by
Apache Software Foundation
Offloader
Filesystem offloader
Use filesystem offloader with Pulsar
Authored by
Apache Software Foundation
Logging
Flume NG Sink
The Flume NG sink connector pulls messages from Pulsar topics to Flume clusters.
Authored by
StreamNative
Sink Connector
Flume Sink
The Flume sink connector pulls messages from Pulsar topics to logs
Authored by
Apache Software Foundation
Source Connector
Flume Source
The Flume source connector pulls messages from logs to Pulsar topics.
Authored by
Apache Software Foundation
Offloader
GCS offloader
Use GCS offloader with Pulsar
Authored by
Apache Software Foundation
Sink Connector
Google Cloud BigQuery Sink Connector
BigQuery Connector integrates Apache Pulsar with Google BigQuery.
Available on
StreamNative Cloud
Authored by
StreamNative
Source Connector
Google Cloud BigQuery Source Connector
BigQuery Connector integrates Apache Pulsar with Google BigQuery.
Available on
StreamNative Cloud
Authored by
StreamNative
Sink Connector
Google Cloud Pub/Sub Sink Connector
Authored by
StreamNative
Source Connector
Google Cloud Pub/Sub Source Connector
Authored by
StreamNative
Sink Connector
Google Cloud Storage Sink Connector
Cloud Storage Connector integrates Apache Pulsar with cloud storage.
Available on
StreamNative Cloud
Authored by
StreamNative
Sink Connector
HBase Sink
The HBase sink connector pulls the messages from Pulsar topics and persists the messages to HBase tables
Authored by
Apache Software Foundation
Sink Connector
HDFS2 Sink
The HDFS2 sink connector pulls the messages from Pulsar topics and persists the messages to HDFS files
Authored by
Apache Software Foundation
Sink Connector
HDFS3 Sink
The HDFS3 sink connector pulls the messages from Pulsar topics and persists the messages to HDFS files.
Authored by
Apache Software Foundation
Sink Connector
InfluxDB Sink
The InfluxDB sink connector pulls messages from Pulsar topics and persists the messages to InfluxDB.
Authored by
Apache Software Foundation
Sink Connector
JDBC Sink
The JDBC sink connector pulls messages from Pulsar topics and persists the messages to MySQL or SQlite.
Authored by
Apache Software Foundation
Sink Connector
Kafka Sink
The Kafka sink connector pulls messages from Pulsar topics and persists the messages to Kafka topics.
Authored by
Apache Software Foundation
Source Connector
Kafka Source
The Kafka source connector pulls messages from Kafka topics and persists the messages to Pulsar topics.
Available on
StreamNative Cloud
Authored by
Apache Software Foundation
Sink Connector
Kinesis Sink
The Kinesis sink connector pulls data from Pulsar and persists data into Amazon Kinesis.
Available on
StreamNative Cloud
Authored by
Apache Software Foundation
Source Connector
Kinesis Source
The Kinesis source connector pulls data from Amazon Kinesis and persists data into Pulsar
Available on
StreamNative Cloud
Authored by
Apache Software Foundation
Protocol Handler
KoP - Kafka on Pulsar
Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar
Authored by
StreamNative
Sink Connector
Lakehouse Sink Connector
pulsar lakehouse connector
Authored by
StreamNative
Source Connector
Lakehouse Source Connector
pulsar lakehouse connector
Authored by
StreamNative
Sink Connector
MongoDB Sink
The MongoDB sink connector pulls messages from Pulsar topics and persists the messages to collections.
Authored by
Apache Software Foundation
Protocol Handler
MoP
MoP brings the native MQTT protocol support to Pulsar by introducing a MQTT protocol handler on Pulsar brokers.
Authored by
StreamNative
Source Connector
Netty Source
The Netty source connector opens a port that accepts incoming data via the configured network protocol and publish it to user-defined Pulsar topics
Authored by
Apache Software Foundation
Monitoring
OpenTracing Pulsar Client
Trace Pulsar messages using OpenTracing Pulsar Client
Authored by
StreamNative
Logging
Pulsar Beat output
The Pulsar Beat output plugin is a lightweight data shipper, written in Go, that you install on your servers to capture all sorts of operational data.
Authored by
StreamNative
Data Processing
Pulsar Flink Connector
Pulsar Flink Connector allows Flink to read data from Pulsar and write data to Pulsar
Authored by
StreamNative
Data Processing
Pulsar Spark Connector
Pulsar Spark Connector allows Spark to read data from Pulsar and write data to Pulsar
Authored by
StreamNative
Sink Connector
RabbitMQ Sink
The RabbitMQ sink connector pulls messages from Pulsar topics and persist the messages to RabbitMQ queues.
Authored by
Apache Software Foundation
Source Connector
RabbitMQ source
The RabbitMQ source connector receives messages from RabbitMQ clusters and writes messages to Pulsar topics
Authored by
Apache Software Foundation
Sink Connector
Redis Sink
The Redis sink connector pulls messages from Pulsar topics and persists the messages to a Redis database.
Authored by
Apache Software Foundation
Sink Connector
Snowflake Sink Connector
Available on
StreamNative Cloud
Authored by
StreamNative
Sink Connector
Solr Sink
The Solr sink connector pulls messages from Pulsar topics and persists the messages to Solr collections.
Authored by
Apache Software Foundation
Source Connector
Twitter Source
The Twitter Firehose source connector receives tweets from Twitter Firehose and writes the tweets to Pulsar topics.
Authored by
Apache Software Foundation