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

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

Debezium MySQL

Debezium PostgreSQL

Debezium MongoDB

DynamoDB

File

Flume

Twitter firehose

Kafka

Kinesis

RabbitMQ

Sink connector

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

Aerospike

Cassandra

ElasticSearch

Flume

HBase

HDFS2

HDFS3

InfluxDB

JDBC MariaDB

JDBC PostgreSQL

JDBC SQLite

Kafka

Kinesis

MongoDB

RabbitMQ

Redis

Solr