Clusters
- Overview
- Cluster Types and Regions
- BYOC
- Manage Instances
- Manage Clusters
- Configure Clusters
- Scale Clusters
- Release Channel
- Geo Replication
- Maintenance Window
Security
- Overview
- Authentication
- Access
- Encrypt And Protect Data
- Monitor Activity
- Manage Secrets
Governance
- Overview
- Kafka Schemas
Connect
- Overview
- Pulsar Io
- Kafka Connect
- Self Host Connectors
Lakehouse
- Lakehosue Storage Feature Parity.md
- Classic Engine
- Ursa Engine
Process
- Pulsar Functions
- Pfsql
- Kafka Streams And Ksql
Networking
- Overview
- Networking On AWS
- Test Connectivity
Universal Linking
Billing
- Overview
- Manage Billing - UI
- View Your Usage - UI
- AWS Marketplace - Pay As You Go
- AWS Marketplace with Commitments
- Google Cloud Marketplace - Pay As You Go
- Google Cloud Marketplace with Commitments
- Azure Cloud Marketplace - Pay As You Go
- Azure Cloud Marketplace with Commitments
- Stop Charges for Your Pulsar Cluster
- FAQ
Deploy Kafka Connectors
Check Kafka Connect Availability
You can check the latest availabiltiy of built-in kafka connectors on StreamNative Cloud using snctl
or kcctl
.
Get built-in Connects
Copy
Ask AI
snctl kafka admin connect get plugins
TYPE CLASS VERSION
sink com.milvus.io.kafka.MilvusSinkConnector 0.1.3
sink com.mongodb.kafka.connect.MongoSinkConnector 1.13.0
sink com.snowflake.kafka.connector.SnowflakeSinkConnector 2.4.1
sink com.wepay.kafka.connect.bigquery.BigQuerySinkConnector 2.5.7
sink io.aiven.connect.elasticsearch.ElasticsearchSinkConnector 7.0.0
sink io.tabular.iceberg.connect.IcebergSinkConnector 0.6.19
source com.mongodb.kafka.connect.MongoSourceConnector 1.13.0
source io.confluent.kafka.connect.datagen.DatagenConnector 0.6.5
source io.debezium.connector.yugabytedb.YugabyteDBConnector 1.9.5.y.220.3
Copy
Ask AI
snctl kafka admin connect get plugins
TYPE CLASS VERSION
sink com.milvus.io.kafka.MilvusSinkConnector 0.1.3
sink com.mongodb.kafka.connect.MongoSinkConnector 1.13.0
sink com.snowflake.kafka.connector.SnowflakeSinkConnector 2.4.1
sink com.wepay.kafka.connect.bigquery.BigQuerySinkConnector 2.5.7
sink io.aiven.connect.elasticsearch.ElasticsearchSinkConnector 7.0.0
sink io.tabular.iceberg.connect.IcebergSinkConnector 0.6.19
source com.mongodb.kafka.connect.MongoSourceConnector 1.13.0
source io.confluent.kafka.connect.datagen.DatagenConnector 0.6.5
source io.debezium.connector.yugabytedb.YugabyteDBConnector 1.9.5.y.220.3
Copy
Ask AI
kcctl get plugins
TYPE CLASS VERSION
sink com.milvus.io.kafka.MilvusSinkConnector 0.1.3
sink com.mongodb.kafka.connect.MongoSinkConnector 1.13.0
sink com.snowflake.kafka.connector.SnowflakeSinkConnector 2.4.1
sink com.wepay.kafka.connect.bigquery.BigQuerySinkConnector 2.5.7
sink io.aiven.connect.elasticsearch.ElasticsearchSinkConnector 7.0.0
sink io.tabular.iceberg.connect.IcebergSinkConnector 0.6.19
source com.mongodb.kafka.connect.MongoSourceConnector 1.13.0
source io.confluent.kafka.connect.datagen.DatagenConnector 0.6.5
source io.debezium.connector.yugabytedb.YugabyteDBConnector 1.9.5.y.220.3
Copy
Ask AI
curl "https://public%2Fdefault:${APIKEY}@${KAFKA-SERVICE-URL}/admin/kafkaconnect/connector-plugins" | jq '.'
[
{
"class": "com.milvus.io.kafka.MilvusSinkConnector",
"type": "sink",
"version": "0.1.3"
},
{
"class": "io.debezium.connector.yugabytedb.YugabyteDBConnector",
"type": "source",
"version": "1.9.5.y.220.3"
},
{
"class": "io.tabular.iceberg.connect.IcebergSinkConnector",
"type": "sink",
"version": "0.6.19"
},
{
"class": "io.aiven.connect.elasticsearch.ElasticsearchSinkConnector",
"type": "sink",
"version": "7.0.0"
},
{
"class": "io.confluent.kafka.connect.datagen.DatagenConnector",
"type": "source",
"version": "0.6.5"
},
{
"class": "com.wepay.kafka.connect.bigquery.BigQuerySinkConnector",
"type": "sink",
"version": "2.5.7"
},
{
"class": "com.snowflake.kafka.connector.SnowflakeSinkConnector",
"type": "sink",
"version": "2.4.1"
},
{
"class": "com.mongodb.kafka.connect.MongoSourceConnector",
"type": "source",
"version": "1.13.0"
},
{
"class": "com.mongodb.kafka.connect.MongoSinkConnector",
"type": "sink",
"version": "1.13.0"
}
]
What’s next?
Was this page helpful?
On this page
Assistant
Responses are generated using AI and may contain mistakes.