• Glossary
  • Support
  • Downloads
  • DataStax Home
Get Live Help
Expand All
Collapse All

DataStax Streaming Home

Luna Streaming Documentation

    • Install & Upgrade
      • Quick Start for Helm Chart installs
      • Quick Start for Bare Metal/VM installs
      • Supported Software
      • Production Cluster Sizing
    • Components & Extensions
      • Pulsar Admin Console
      • Install Pulsar Admin Console on Server/VM
      • Pulsar Heartbeat
      • Heartbeat on VM/Server
      • Pulsar Beam
      • Pulsar SQL
      • Starlight for Kafka
      • Starlight for RabbitMQ
    • Operations
      • Luna Streaming Authentication
      • Luna Streaming Functions
      • Luna Streaming IO connectors
      • Scaling your Luna Streaming cluster
      • Troubleshooting
  • Luna Streaming Documentation
  • Operations
  • Luna Streaming IO connectors
2.10-3.x 2.10-2.x 2.10-1.x
Edit this Page

Luna Streaming IO connectors

When you have Luna Streaming installed and running, add IO connectors to connect your deployment to external systems like Apache Cassandra, ElasticSearch, and more.

There are three versions of the DataStax Luna Streaming distribution. The lunastreaming-all version contains all connectors.

Sink Connectors

AstraDB sink

The AstraDB sink connector reads messages from Apache Pulsar topics and writes them to AstraDB systems.

AstraDB sink documentation

ElasticSearch sink

The Elasticsearch sink connector reads messages from Apache Pulsar topics and writes them to Elasticsearch systems.

Elasticsearch sink documentation

JDBC-Clickhouse sink

The JDBC-ClickHouse sink connector reads messages from Apache Pulsar topics and writes them to JDBC-ClickHouse systems.

JDBC ClickHouse sink documentation

JDBC-MariaDB sink

The JDBC-MariaDB sink connector reads messages from Apache Pulsar topics and writes them to JDBC-MariaDB systems.

JDBC MariaDB sink documentation

JDBC-PostgreSQL sink

The JDBC-PostgreSQL sink connector reads messages from Apache Pulsar topics and writes them to JDBC-PostgreSQL systems.

JDBC PostgreSQL sink documentation

JDBC-SQLite

The JDBC-SQLite sink connector reads messages from Apache Pulsar topics and writes them to JDBC-SQLite systems.

JDBC SQLite sink documentation

Kafka

The Kafka sink connector reads messages from Apache Pulsar topics and writes them to Kafka systems.

Kafka sink documentation

Kinesis

The Kinesis sink connector reads messages from Apache Pulsar topics and writes them to Kinesis systems.

Kinesis sink documentation

Snowflake

The Snowflake sink connector reads messages from Apache Pulsar topics and writes them to Snowflake systems.

Snowflake sink documentation

Source Connectors

Data Generator source

The Data generator source connector produces messages for testing and persists the messages to Pulsar topics.

Data Generator source documentation

Debezium MongoDB source

The Debezium MongoDB source connector reads data from Debezium MongoDB systems and produces data to Pulsar topics.

Debezium MongoDB source documentation

Debezium MySQL source

The Debezium MySQL source connector reads data from Debezium MySQL systems and produces data to Pulsar topics.

Debezium MySQL source documentation

Debezium Oracle source

The Debezium Oracle source connector reads data from Debezium Oracle systems and produces data to Pulsar topics.

Debezium Oracle source documentation

Debezium Postgres source

The Debezium PostgreSQL source connector reads data from Debezium PostgreSQL systems and produces data to Pulsar topics.

Debezium PostgreSQL source documentation

Debezium SQL Server source

The Debezium SQL Server source connector reads data from Debezium SQL Server systems and produces data to Pulsar topics.

Debezium SQL Server source documentation

Kafka source

The Kafka source connector reads data from Kafka systems and produces data to Pulsar topics.

Kafka source connector documentation

AWS Kinesis source

The AWS Kinesis source connector reads data from Kinesis systems and produces data to Pulsar topics.

Kinesis source connector documentation

Experimental Connectors

DataStax is always experimenting with connectors. Below are the connectors available in the luna-streaming-all version of Luna Streaming. We call these experimental connectors because they have not yet been promoted to official support in our Astra Streaming clusters, but they will work in your Luna Streaming cluster.

Sink Connectors (experimental)

Cloud Storage
Kinetica
Aerospike
Azure DocumentDB
Azure Data Explorer (Kusto)
Batch Data Generator
Big Query
CoAP
Couchbase
DataDog
Diffusion
Flume
Apache Geode
Hazelcast
Apache HBase
HDFS 2
HDFS 3
Humio
InfluxDB
JMS
Apache Kudu
MarkLogic
MongoDB
MQTT
Neo4J
New Relic
OrientDB
Apache Phoenix
PLC4X
RabbitMQ
Redis
SAP HANA
SingleStore
Apache Solr
Splunk
XTDB
Zeebe

Source Connectors (experimental)

Cassandra Source
Kinetica
Azure DocumentDB
Batch Data Generator
Big Query
canal
CoAP
Couchbase
datadog
diffusion
DynamoDB
file
flume
Apache Geode
Hazelcast
Humio
JMS
Apache Kudu
MarkLogic
MongoDB
MQTT
Neo4J
Netty
New Relic
NSQ
OrientDB
Apache Phoenix
PLC4X
RabbitMQ
Redis
SAP HANA
SingleStore
Splunk
Twitter
XTDB
Zeebe

What’s next?

For more on connectors and Pulsar, see our Connectors learning page, or check the Pulsar documentation.

Luna Streaming Functions Scaling your Luna Streaming cluster

General Inquiries: +1 (650) 389-6000 info@datastax.com

© DataStax | Privacy policy | Terms of use

DataStax, Titan, and TitanDB are registered trademarks of DataStax, Inc. and its subsidiaries in the United States and/or other countries.

Apache, Apache Cassandra, Cassandra, Apache Tomcat, Tomcat, Apache Lucene, Apache Solr, Apache Hadoop, Hadoop, Apache Pulsar, Pulsar, Apache Spark, Spark, Apache TinkerPop, TinkerPop, Apache Kafka and Kafka are either registered trademarks or trademarks of the Apache Software Foundation or its subsidiaries in Canada, the United States and/or other countries.

Kubernetes is the registered trademark of the Linux Foundation.

landing_page landingpage