StreamNative Hub

Cloud Console Support Portal

StreamNative Hub

Discover Apache Pulsar Ecosystem

IO Connectors
1. Sources
2. Sinks

Integrations
1. Offloaders
2. Protocol handlers

Plugins
1. Logging
2. Monitoring
3. Data processing

Support type
1. StreamNative Cloud managed

1. Submit plugin

StreamNative Cloud managed
Sink Connector
ActiveMQ Sink
The ActiveMQ sink connector pulls messages from Pulsar topics and persist messages to ActiveMQ clusters.
StreamNative
StreamNative Cloud managed
Source Connector
ActiveMQ Source
The ActiveMQ source connector receives messages from ActiveMQ clusters and writes messages to Pulsar topics.
StreamNative
StreamNative Cloud managed
Sink Connector
Aerospike Sink
The Aerospike sink connector pulls messages from Pulsar topics to Aerospike clusters
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
AMQP1_0 Sink Connector
support sink/source for AMQP version 1.0.0
StreamNative
StreamNative Cloud managed
Source Connector
AMQP1_0 Source Connector
support sink/source for AMQP version 1.0.0
StreamNative
StreamNative Cloud managed
Protocol Handler
AoP
AoP brings the native AMQP protocol support to Pulsar by introducing an AMQP protocol handler on Pulsar brokers.
StreamNative
StreamNative Cloud managed
Sink Connector
AWS EventBridge Sink Connector
StreamNative
StreamNative Cloud managed
Sink Connector
AWS Lambda Sink
StreamNative
StreamNative Cloud managed
Offloader
AWS S3 offloader
Use AWS S3 offloader with Pulsar
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
AWS SQS Sink Connector
StreamNative
StreamNative Cloud managed
Source Connector
AWS SQS Source Connector
StreamNative
StreamNative Cloud managed
Source Connector
Canal Source
The Canal source connector pulls messages from MySQL to Pulsar topics.
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
Cassandra Sink
The Cassandra sink connector pulls messages from Pulsar topics to Cassandra clusters
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
Cloud Storage Sink Connector
Cloud Storage Connector integrates Apache Pulsar with cloud storage.
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
Apache Software Foundation
StreamNative Cloud managed
Source Connector
Debezium MongoDB Source
The Debezium MongoDB source connector pulls messages from MongoDB and persists the messages to Pulsar topics
Apache Software Foundation
Source Connector
Debezium MySQL Source
The Debezium source connector pulls messages from MySQL and persists the messages to Pulsar topics.
Apache Software Foundation
StreamNative Cloud managed
Source Connector
Debezium PostgreSQL Source
The Debezium source connector pulls messages from PostgreSQL and persists the messages to Pulsar topics.
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
Elasticsearch Sink Connector
The Elasticsearch sink connector pulls messages from Pulsar topics and persists the messages to indexes
Apache Software Foundation
Source Connector
File Source
The File source connector pulls messages from files in directories and persists the messages to Pulsar topics.
Apache Software Foundation
StreamNative Cloud managed
Offloader
Filesystem offloader
Use filesystem offloader with Pulsar
Apache Software Foundation
StreamNative Cloud managed
Logging
Flume NG Sink
The Flume NG sink connector pulls messages from Pulsar topics to Flume clusters.
StreamNative
StreamNative Cloud managed
Sink Connector
Flume Sink
The Flume sink connector pulls messages from Pulsar topics to logs
Apache Software Foundation
StreamNative Cloud managed
Source Connector
Flume Source
The Flume source connector pulls messages from logs to Pulsar topics.
Apache Software Foundation
StreamNative Cloud managed
Offloader
GCS offloader
Use GCS offloader with Pulsar
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
Google Cloud BigQuery Sink Connector
BigQuery Connector integrates Apache Pulsar with Google BigQuery.
StreamNative
StreamNative Cloud managed
Source Connector
Google Cloud BigQuery Source Connector
BigQuery Connector integrates Apache Pulsar with Google BigQuery.
StreamNative
StreamNative Cloud managed
Sink Connector
Google Cloud Pub/Sub Sink Connector
StreamNative
StreamNative Cloud managed
Source Connector
Google Cloud Pub/Sub Source Connector
StreamNative
StreamNative Cloud managed
Sink Connector
HBase Sink
The HBase sink connector pulls the messages from Pulsar topics and persists the messages to HBase tables
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
HDFS2 Sink
The HDFS2 sink connector pulls the messages from Pulsar topics and persists the messages to HDFS files
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
HDFS3 Sink
The HDFS3 sink connector pulls the messages from Pulsar topics and persists the messages to HDFS files.
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
InfluxDB Sink
The InfluxDB sink connector pulls messages from Pulsar topics and persists the messages to InfluxDB.
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
JDBC Sink
The JDBC sink connector pulls messages from Pulsar topics and persists the messages to MySQL or SQlite.
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
Kafka Sink
The Kafka sink connector pulls messages from Pulsar topics and persists the messages to Kafka topics.
Apache Software Foundation
StreamNative Cloud managed
Source Connector
Kafka Source
The Kafka source connector pulls messages from Kafka topics and persists the messages to Pulsar topics.
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
Kinesis Sink
The Kinesis sink connector pulls data from Pulsar and persists data into Amazon Kinesis.
Apache Software Foundation
StreamNative Cloud managed
Source Connector
Kinesis Source
The Kinesis source connector pulls data from Amazon Kinesis and persists data into Pulsar
Apache Software Foundation
StreamNative Cloud managed
Protocol Handler
KoP - Kafka on Pulsar
Kafka-on-Pulsar - A protocol handler that brings native Kafka protocol to Apache Pulsar
StreamNative
StreamNative Cloud managed
Sink Connector
Lakehouse Sink Connector
pulsar lakehouse connector
StreamNative
StreamNative Cloud managed
Source Connector
Lakehouse Source Connector
pulsar lakehouse connector
StreamNative
StreamNative Cloud managed
Sink Connector
MongoDB Sink
The MongoDB sink connector pulls messages from Pulsar topics and persists the messages to collections.
Apache Software Foundation
StreamNative Cloud managed
Protocol Handler
MoP
MoP brings the native MQTT protocol support to Pulsar by introducing a MQTT protocol handler on Pulsar brokers.
StreamNative
StreamNative Cloud managed
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
Apache Software Foundation
StreamNative Cloud managed
Monitoring
OpenTracing Pulsar Client
Trace Pulsar messages using OpenTracing Pulsar Client
StreamNative
StreamNative Cloud managed
Data Processing
Pulsar Flink Connector
Pulsar Flink Connector allows Flink to read data from Pulsar and write data to Pulsar
StreamNative
StreamNative Cloud managed
Data Processing
Pulsar Spark Connector
Pulsar Spark Connector allows Spark to read data from Pulsar and write data to Pulsar
StreamNative
StreamNative Cloud managed
Logging
pulsar-beat-output
Elastic Beats Output to Apache Pulsar
StreamNative
StreamNative Cloud managed
Sink Connector
RabbitMQ Sink
The RabbitMQ sink connector pulls messages from Pulsar topics and persist the messages to RabbitMQ queues.
Apache Software Foundation
StreamNative Cloud managed
Source Connector
RabbitMQ source
The RabbitMQ source connector receives messages from RabbitMQ clusters and writes messages to Pulsar topics
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
Redis Sink
The Redis sink connector pulls messages from Pulsar topics and persists the messages to a Redis database.
Apache Software Foundation
StreamNative Cloud managed
Sink Connector
Snowflake Sink Connector
StreamNative
StreamNative Cloud managed
Sink Connector
Solr Sink
The Solr sink connector pulls messages from Pulsar topics and persists the messages to Solr collections.
Apache Software Foundation
StreamNative Cloud managed
Source Connector
Twitter Source
The Twitter Firehose source connector receives tweets from Twitter Firehose and writes the tweets to Pulsar topics.
Apache Software Foundation

1. Submit plugin