data/connectors.js (188 lines of code) (raw):

module.exports = [ { name: 'aerospike', longName: 'Aerospike sink', type: 'Sink', link: 'https://www.aerospike.com/' }, { name: 'canal', longName: 'Alibaba Canal CDC source', type: 'Source', link: 'https://github.com/alibaba/canal' }, { name: 'cassandra', longName: 'Apache Cassandra source and sink', type: 'Source and sink', link: 'https://cassandra.apache.org' }, { name: 'kafka-connect-adaptor', longName: 'Apache Kafka Connect Adaptor source and sink', type: 'Source and sink', link: 'http://kafka.apache.org/' }, { name: 'dynamodb', longName: 'AWS DynamoDB source', type: 'Source', link: 'https://aws.amazon.com/dynamodb/' }, { name: 'kinesis', longName: 'AWS Kinesis source and sink', type: 'Source and sink', link: 'https://aws.amazon.com/kinesis/' }, { name: 'debezium-mysql', longName: 'Debezium MySQL CDC source', type: 'Source', link: 'https://debezium.io/' }, { name: 'debezium-postgres', longName: 'Debezium PostgreSQL CDC source', type: 'Source', link: 'https://debezium.io/' }, { name: 'debezium-mongodb', longName: 'Debezium MongoDB CDC source', type: 'Source', link: 'https://debezium.io/' }, { name: 'debezium-mssql', longName: 'Debezium SQL Server CDC source', type: 'Source', link: 'https://debezium.io/' }, { name: 'debezium-oracle', longName: 'Debezium Oracle CDC source', type: 'Source', link: 'https://debezium.io/' }, { name: 'elastic-search', longName: 'ElasticSearch source and sink', type: 'Source and sink', link: 'https://www.elastic.co/' }, { name: 'file', longName: 'File source', type: 'Source', link: 'https://github.com/apache/pulsar/tree/master/pulsar-io/file' }, { name: 'flume', longName: 'Flume source and sink', type: 'Source and sink', link: 'https://flume.apache.org/' }, { name: 'hbase', longName: 'HBase sink', type: 'Sink', link: 'https://hbase.apache.org/' }, { name: 'hdfs3', longName: 'HDFS3 sink', type: 'Sink', link: 'https://hadoop.apache.org/' }, { name: 'http', longName: 'HTTP sink', type: 'Sink', link: 'https://github.com/apache/pulsar/tree/master/pulsar-io/http' }, { name: 'influxdb', longName: 'InfluxDB sink', type: 'Sink', link: 'https://www.influxdata.com/' }, { name: 'jdbc-clickhouse', longName: 'JDBC ClickHouse sink', type: 'Sink', link: 'https://clickhouse.tech/' }, { name: 'jdbc-mariadb', longName: 'JDBC MariaDB sink', type: 'Sink', link: 'https://mariadb.org/' }, { name: 'jdbc-postgres', longName: 'JDBC PostgresSQL sink', type: 'Sink', link: 'https://www.postgresql.org/' }, { name: 'jdbc-sqlite', longName: 'JDBC SQLite sink', type: 'Sink', link: 'https://www.sqlite.org/' }, { name: 'kafka', longName: 'Kafka source and sink', type: 'Source and sink', link: 'https://kafka.apache.org/' }, { name: 'mongo', longName: 'MongoDB sink', type: 'Sink', link: 'https://www.mongodb.com/' }, { name: 'netty', longName: 'Netty source', type: 'Source', link: 'https://netty.io/' }, { name: 'nsq', longName: 'NSQ source', type: 'Source', link: 'https://nsq.io/', }, { name: 'rabbitmq', longName: 'RabbitMQ source and sink', type: 'Source and sink', link: 'https://www.rabbitmq.com/' }, { name: 'redis', longName: 'Redis sink', type: 'Sink', link: 'https://redis.io/' }, { name: 'solr', longName: 'Solr sink', type: 'Sink', link: 'https://lucene.apache.org/solr/' }, { name: 'data-generator', longName: 'Test Data Generator source', type: 'Source', link: 'https://github.com/apache/pulsar/tree/master/pulsar-io/data-generator' }, { name: 'twitter', longName: 'Twitter Firehose source', type: 'Source', link: 'https://developer.twitter.com/en/docs' } ]