Skip to main content
Version: 3.2.x

Built-in connector

Pulsar distribution includes a set of common connectors that have been packaged and tested with the rest of Apache Pulsar. These built-in connectors import and export data from some of the most commonly used data systems.

Using any of these built-in connectors is as easy as writing a simple connector and running the connector locally or submitting the connector to a Pulsar Functions cluster.

Source connector​

Pulsar has various source connectors, which are sorted alphabetically as below.

Canal​

Debezium MySQL​

Debezium PostgreSQL​

Debezium MongoDB​

Debezium Oracle​

Debezium Microsoft SQL Server​

DynamoDB​

File​

Flume​

Twitter firehose​

Kafka​

Kinesis​

MongoDB​

Netty​

NSQ​

RabbitMQ​

Sink connector​

Pulsar has various sink connectors, which are sorted alphabetically as below.

Aerospike​

Alluxio​

Cassandra​

ElasticSearch​

Flume​

HBase​

HDFS2​

HDFS3​

HTTP​

InfluxDB​

JDBC ClickHouse​

JDBC MariaDB​

JDBC OpenMLDB​

JDBC PostgreSQL​

JDBC SQLite​

Kafka​

Kinesis​

MongoDB​

RabbitMQ​

Redis​

Solr​