Built-in connector

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

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

    Debezium MySQL

    Debezium PostgreSQL

    Debezium MongoDB

    DynamoDB

    File

    Flume

    Twitter firehose

    Kafka

    Kinesis

    NSQ

    RabbitMQ

    Sink connector

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

    Aerospike

    Cassandra

    ElasticSearch

    Flume

    HBase

    HDFS2

    HDFS3

    JDBC ClickHouse

    JDBC MariaDB

    JDBC PostgreSQL

    JDBC SQLite

    Kafka

    Kinesis

    MongoDB

    RabbitMQ

    Redis