Built-in connector

Pulsar 的发行版中包含一组公共 connector，这些 connector 是 Pulsar 安装包的一部分，并且和安装包其余部分一起测试过。 这些 connector 从一些最常用的数据系统导入、导出数据。 For a full set of third-party connectors that Pulsar supports, refer to StreamNative Hub.

使用其中任一 connector 都很简单，就像写入简单的 connector 并在本地运行一样，或是将 connector 提交到 Pulsar Functions 集群。

Source connector

Pulsar 里有多种 source connector，按首字母顺序排列如下所示。

Canal

Debezium MySQL

Debezium PostgreSQL

Debezium MongoDB

DynamoDB

File

Flume

Twitter firehose

Kafka

Kinesis

Netty

NSQ

RabbitMQ

Sink connector

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

Aerospike

Cassandra

ElasticSearch

Flume

HBase

HDFS2

HDFS3

InfluxDB

JDBC ClickHouse

JDBC MariaDB

JDBC PostgreSQL

JDBC SQLite

Kafka

Kinesis

MongoDB

RabbitMQ

Redis

Solr