Как удалить плагин коннектора в Кафке - PullRequest
0 голосов
/ 25 мая 2018

Вот список плагинов моего коннектора:

> curl localhost:8083/connector-plugins
{
    "class": "io.confluent.connect.activemq.ActiveMQSourceConnector",
    "type": "source",
    "version": "4.1.0"
}, {
    "class": "io.confluent.connect.elasticsearch.ElasticsearchSinkConnector",
    "type": "sink",
    "version": "4.1.0"
}, {
    "class": "io.confluent.connect.hdfs.HdfsSinkConnector",
    "type": "sink",
    "version": "4.1.0"
}, {
    "class": "io.confluent.connect.hdfs.tools.SchemaSourceConnector",
    "type": "source",
    "version": "1.1.0-cp1"
}, {
    "class": "io.confluent.connect.ibm.mq.IbmMQSourceConnector",
    "type": "source",
    "version": "4.1.0"
}, {
    "class": "io.confluent.connect.jdbc.JdbcSinkConnector",
    "type": "sink",
    "version": "4.1.0"
}, {
    "class": "io.confluent.connect.jdbc.JdbcSourceConnector",
    "type": "source",
    "version": "4.1.0"
}, {
    "class": "io.confluent.connect.jms.JmsSourceConnector",
    "type": "source",
    "version": "4.1.0"
}, {
    "class": "io.confluent.connect.replicator.ReplicatorSourceConnector",
    "type": "source",
    "version": "4.1.0"
}, {
    "class": "io.confluent.connect.s3.S3SinkConnector",
    "type": "sink",
    "version": "4.1.0"
}, {
    "class": "io.confluent.connect.storage.tools.SchemaSourceConnector",
    "type": "source",
    "version": "1.1.0-cp1"
}, {
    "class": "io.debezium.connector.mysql.MySqlConnector",
    "type": "source",
    "version": "0.7.5"
}, {
    "class": "org.apache.kafka.connect.file.FileStreamSinkConnector",
    "type": "sink",
    "version": "1.1.0-cp1"
}, {
    "class": "org.apache.kafka.connect.file.FileStreamSourceConnector",
    "type": "source",
    "version": "1.1.0-cp1"
}

Как удалить следующий коннектор?

{
    "class": "io.debezium.connector.mysql.MySqlConnector",
    "type": "source",
    "version": "0.7.5"
}

1 Ответ

0 голосов
/ 25 мая 2018

Удалите его из вашего plugin.path.

...