Built-in connector
Pulsar 的发行版中包含一组公共 connector,这些 connector 是 Pulsar 安装包的一部分,并且和安装包其余部分一起测试过。 这些 connector 从一些最常用的数据系统导入、导出数据。
使用其中任一 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 里有多种 sink connector,按首字母顺序排列如下所示。