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.

ElasticSearch sink

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

JDBC-Clickhouse sink

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

JDBC-MariaDB sink

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

JDBC-PostgreSQL sink

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

JDBC-SQLite

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

Kafka

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

Kinesis

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

Snowflake

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

Source Connectors

Data Generator source

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

Debezium MongoDB source

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

Debezium MySQL source

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

Debezium Oracle source

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

Debezium Postgres source

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

Debezium SQL Server source

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

Kafka source

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

AWS Kinesis source

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

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

Next steps

For more on connectors and Pulsar, see Connectors and the Pulsar documentation.

Was this helpful?

Give Feedback

How can we improve the documentation?

© 2025 DataStax, an IBM Company | Privacy policy | Terms of use | Manage Privacy Choices

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.

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