- Connect to External Systems
- 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 |
+-----------------+----------------------------------------+------------------------------------------------------------------+