1. Connect to External Systems
  2. Pulsar IO

Check Connector Availability

You can check the latest availabiltiy of built-in connectors on StreamNative Cloud using pulsarctl or pulsar-admin.

Check Source Connector Availability

 pulsarctl sources available-sources

+-------------------+-----------------------------------------+--------------------------------------------------------------+
|       NAME        |             DESCRIPTION                 |                           CLASSNAME                          |
+-------------------+-----------------------------------------+--------------------------------------------------------------+
| amqp1_0           | AMQP1_0 [email protected]              | org.apache.pulsar.ecosystem.io.amqp.AmqpSource               |
| bigquery          | Google BigQuery [email protected]    | org.apache.pulsar.ecosystem.io.bigquery.BigQuerySource       |
| data-generator    | Test data generator [email protected]  | org.apache.pulsar.io.datagenerator.DataGeneratorSource       |
| debezium-mongodb  | Debezium MongoDb [email protected]        | org.apache.pulsar.io.debezium.mongodb.DebeziumMongoDbSource  |
| debezium-mssql    | Debezium Microsoft SQL [email protected]  | org.apache.pulsar.io.debezium.mssql.DebeziumMsSqlSource      |
| debezium-mysql    | Debezium MySql [email protected]          | org.apache.pulsar.io.debezium.mysql.DebeziumMysqlSource      |
| debezium-postgres | Debezium Postgres [email protected]       | org.apache.pulsar.io.debezium.postgres.DebeziumPostgresSource|
| kafka             | Kafka [email protected]                   | org.apache.pulsar.io.kafka.KafkaBytesSource                  |
| kinesis           | Kinesis [email protected]             | org.apache.pulsar.io.kinesis.KinesisSource                   |
| sqs               | SQS [email protected]                 | org.apache.pulsar.ecosystem.io.sqs.SQSSource                 |
+-------------------+-----------------------------------------+--------------------------------------------------------------+

Check Sink Connector Availability

 pulsarctl sinks available-sinks
+-----------------+----------------------------------------+------------------------------------------------------------------+
| NAME            | DESCRIPTION                            | CLASSNAME                                                        |
+-----------------+----------------------------------------+------------------------------------------------------------------+
| amqp1_0         | AMQP1_0 connectors @2.8.2.4            | org.apache.pulsar.ecosystem.io.amqp.AmqpSink                     |
| aws-eventbridge | AWS EventBridge Sink @2.10.4.3         | org.apache.pulsar.io.eventbridge.sink.EventBridgeSink            |
| aws-lambda      | AWS Lambda Sink @2.9.2.17              | org.apache.pulsar.ecosystem.io.aws.lambda.AWSLambdaBytesSink     |
| bigquery        | Google BigQuery connectors @2.10.1.12  | org.apache.pulsar.ecosystem.io.bigquery.BigQuerySink             |
| cloud-storage   | Cloud storage Sink @2.9.4.3            | org.apache.pulsar.io.jcloud.sink.CloudStorageGenericRecordSink   |
| data-generator  | Test data generator connector @2.9.2.17| org.apache.pulsar.io.datagenerator.DataGeneratorPrintSink        |
| elasticsearch   | Elasticsearch Sink @2.10.0.3           | org.apache.pulsar.io.elasticsearch.ElasticSearchSink             |
| kinesis         | Kinesis connectors @2.9.2.17           | org.apache.pulsar.io.kinesis.KinesisSink                         |
| snowflake       | Snowflake Sink @2.10.3.4               | org.apache.pulsar.ecosystem.io.snowflake.SnowflakeSinkConnector  |
| sqs             | SQS connectors @2.9.2.18               | org.apache.pulsar.ecosystem.io.sqs.SQSSink                       |
+-----------------+----------------------------------------+------------------------------------------------------------------+

What’s next?

Previous
Set up Your Environment