id: io-connectors title: Built-in connector sidebar_label: 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.

NameJava class
Canalorg.apache.pulsar.io.canal.CanalStringSource.java
Debezium MySQLorg.apache.pulsar.io.debezium.mysql.DebeziumMysqlSource.java
Debezium PostgreSQLorg.apache.pulsar.io.debezium.postgres.DebeziumPostgresSource.java
Fileorg.apache.pulsar.io.file.FileSource.java
Flumeorg.apache.pulsar.io.flume.FlumeConnector.java
Twitter firehoseorg.apache.pulsar.io.twitter.TwitterFireHose.java
Kafkaorg.apache.pulsar.io.kafka.KafkaAbstractSource.java
Kinesisorg.apache.pulsar.io.kinesis.KinesisSource.java
Nettyorg.apache.pulsar.io.netty.NettySource.java
RabbitMQorg.apache.pulsar.io.rabbitmq.RabbitMQSource.java

Sink connector

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

NameJava class
Aerospikeorg.apache.pulsar.io.aerospike.AerospikeStringSink.java
Cassandraorg.apache.pulsar.io.cassandra.CassandraStringSink.java
ElasticSearchorg.apache.pulsar.io.elasticsearch.ElasticSearchSink.java
Flumeorg.apache.pulsar.io.flume.sink.StringSink.java
HBaseorg.apache.pulsar.io.hbase.HbaseAbstractConfig.java
HDFS2org.apache.pulsar.io.hdfs2.AbstractHdfsConnector.java
HDFS3org.apache.pulsar.io.hdfs3.AbstractHdfsConnector.java
InfluxDBorg.apache.pulsar.io.influxdb.InfluxDBAbstractSink.java
JDBCorg.apache.pulsar.io.jdbc.JdbcAbstractSink.java
Kafkaorg.apache.pulsar.io.kafka.KafkaAbstractSink.java
Kinesisorg.apache.pulsar.io.kinesis.KinesisSink.java
MongoDBorg.apache.pulsar.io.mongodb.MongoSink.java
RabbitMQorg.apache.pulsar.io.rabbitmq.RabbitMQSink.java
Redisorg.apache.pulsar.io.redis.RedisAbstractConfig.java
Solrorg.apache.pulsar.io.solr.SolrSinkConfig.java