Pulsar I/O connectors in Astra Streaming
|
Effective October 9, 2026, Astra Streaming subscriptions are discontinued and the service is considered deprecated. For existing subscriptions, access to the service remains available for the duration of your subscription. For more information, see the Astra Streaming discontinuation announcement, contact your account representative, or contact IBM Support. |
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.
