Built-in connector

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

Using any of these 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