snctl or kcctl.
Get Built-in Connectors
- snctl
- kcctl
- Rest API
Copy
Ask AI
snctl kafka admin connect get plugins
TYPE CLASS VERSION
sink com.milvus.io.kafka.MilvusSinkConnector 1.0.1
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.aiven.connect.jdbc.JdbcSinkConnector 6.10.0
sink io.debezium.connector.jdbc.JdbcSinkConnector 3.2.0.Final
sink io.tabular.iceberg.connect.IcebergSinkConnector 0.6.19
source com.mongodb.kafka.connect.MongoSourceConnector 1.13.0
source io.aiven.connect.jdbc.JdbcSourceConnector 6.10.0
source io.confluent.kafka.connect.datagen.DatagenConnector 0.6.5
source io.debezium.connector.mongodb.MongoDbConnector 3.2.0.Final
source io.debezium.connector.mysql.MySqlConnector 3.2.0.Final
source io.debezium.connector.postgresql.PostgresConnector 3.2.0.Final
source io.debezium.connector.sqlserver.SqlServerConnector 3.2.0.Final
source io.debezium.connector.yugabytedb.YugabyteDBConnector 1.9.5.y.220.3
source io.jrnd.kafka.connect.connector.JRSourceConnector 0.4.0
Copy
Ask AI
kcctl get plugins
TYPE CLASS VERSION
sink com.milvus.io.kafka.MilvusSinkConnector 1.0.1
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.aiven.connect.jdbc.JdbcSinkConnector 6.10.0
sink io.debezium.connector.jdbc.JdbcSinkConnector 3.2.0.Final
sink io.tabular.iceberg.connect.IcebergSinkConnector 0.6.19
source com.mongodb.kafka.connect.MongoSourceConnector 1.13.0
source io.aiven.connect.jdbc.JdbcSourceConnector 6.10.0
source io.confluent.kafka.connect.datagen.DatagenConnector 0.6.5
source io.debezium.connector.mongodb.MongoDbConnector 3.2.0.Final
source io.debezium.connector.mysql.MySqlConnector 3.2.0.Final
source io.debezium.connector.postgresql.PostgresConnector 3.2.0.Final
source io.debezium.connector.sqlserver.SqlServerConnector 3.2.0.Final
source io.debezium.connector.yugabytedb.YugabyteDBConnector 1.9.5.y.220.3
source io.jrnd.kafka.connect.connector.JRSourceConnector 0.4.0
Copy
Ask AI
curl "https://public%2Fdefault:${APIKEY}@${KAFKA-SERVICE-URL}/admin/kafkaconnect/connector-plugins" | jq '.'
[
{
"class": "io.debezium.connector.mongodb.MongoDbConnector",
"type": "source",
"version": "3.2.0.Final"
},
{
"class": "io.aiven.connect.jdbc.JdbcSinkConnector",
"type": "sink",
"version": "6.10.0"
},
{
"class": "io.debezium.connector.yugabytedb.YugabyteDBConnector",
"type": "source",
"version": "1.9.5.y.220.3"
},
{
"class": "io.confluent.kafka.connect.datagen.DatagenConnector",
"type": "source",
"version": "0.6.5"
},
{
"class": "io.debezium.connector.postgresql.PostgresConnector",
"type": "source",
"version": "3.2.0.Final"
},
{
"class": "io.debezium.connector.mysql.MySqlConnector",
"type": "source",
"version": "3.2.0.Final"
},
{
"class": "io.debezium.connector.sqlserver.SqlServerConnector",
"type": "source",
"version": "3.2.0.Final"
},
{
"class": "io.jrnd.kafka.connect.connector.JRSourceConnector",
"type": "source",
"version": "0.4.0"
},
{
"class": "com.milvus.io.kafka.MilvusSinkConnector",
"type": "sink",
"version": "1.0.1"
},
{
"class": "io.tabular.iceberg.connect.IcebergSinkConnector",
"type": "sink",
"version": "0.6.19"
},
{
"class": "com.mongodb.kafka.connect.MongoSinkConnector",
"type": "sink",
"version": "1.13.0"
},
{
"class": "com.wepay.kafka.connect.bigquery.BigQuerySinkConnector",
"type": "sink",
"version": "2.5.7"
},
{
"class": "io.aiven.connect.jdbc.JdbcSourceConnector",
"type": "source",
"version": "6.10.0"
},
{
"class": "io.debezium.connector.jdbc.JdbcSinkConnector",
"type": "sink",
"version": "3.2.0.Final"
},
{
"class": "com.snowflake.kafka.connector.SnowflakeSinkConnector",
"type": "sink",
"version": "2.4.1"
},
{
"class": "io.aiven.connect.elasticsearch.ElasticsearchSinkConnector",
"type": "sink",
"version": "7.0.0"
},
{
"class": "com.mongodb.kafka.connect.MongoSourceConnector",
"type": "source",
"version": "1.13.0"
}
]
In addition to the built-in connectors, you can also deploy any custom connectors. For more information, see Deploy Custom Connectors.