Pulsar I/O connectors in Astra Streaming

Astra Streaming offers fully-managed versions of Apache Pulsar™ sink and source connectors.

Astra Streaming doesn’t support custom sink or source connectors.

Sink connectors

Sink connectors export messages from Pulsar topics to external services.

Supported sink connectors

The following sink connectors are included in Astra Streaming:

Experimental sink connectors

The following sink connectors are experimental. They are in development, and they aren’t fully supported or tested with Astra Streaming. To get access to experimental connectors, contact DataStax Support.

  • Aerospike

  • Apache Geode

  • Apache HBase

  • Apache Kudu

  • Apache Phoenix

  • Apache Solr

  • Batch Data Generator

  • CoAP

  • Couchbase

  • DataDog

  • Diffusion

  • Flume

  • Hazelcast

  • HDFS 2

  • HDFS 3

  • Humio

  • InfluxDB

  • JMS

  • Kinetica

  • MarkLogic

  • Microsoft Azure Data Explorer (Kusto)

  • Microsoft Azure DocumentDB

  • MongoDB

  • MQTT

  • Neo4J

  • New Relic

  • OrientDB

  • PLC4X

  • RabbitMQ

  • Redis

  • SAP HANA

  • SingleStore

  • Splunk

  • XTDB

  • Zeebe

Source connectors

Source connectors ingest messages from external services into Pulsar topics.

Supported source connectors

The following source connectors are included in Astra Streaming:

Experimental source connectors

The following source connectors are experimental. They are in development, and they aren’t fully supported or tested with Astra Streaming. To get access to experimental connectors, contact DataStax Support.

  • Apache Cassandra

  • Apache Geode

  • Apache Kudu

  • Apache Phoenix

  • Batch Data Generator

  • Big Query

  • Canal

  • CoAP

  • Couchbase

  • DataDog

  • Diffusion

  • DynamoDB

  • File

  • Flume

  • Hazelcast

  • Humio

  • JMS

  • Kinetica

  • MarkLogic

  • Microsoft Azure DocumentDB

  • MongoDB

  • MQTT

  • Neo4J

  • New Relic

  • NSQ

  • OrientDB

  • PLC4X

  • RabbitMQ

  • Redis

  • SAP HANA

  • SingleStore

  • Splunk

  • Twitter

  • XTDB

  • Zeebe

Create and manage connectors

You can use the Astra Portal, the pulsar-admin CLI, or the Pulsar Admin API to create, monitor, and manage sink and source connectors:

Connector metrics

Astra Streaming exposes Prometheus-formatted metrics for every connector. For more information, see Scrape Astra Streaming metrics with Prometheus.

Was this helpful?

Give Feedback

How can we improve the documentation?

© Copyright IBM Corporation 2026 | 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: Contact IBM