Kafka Connect - 如何删除连接器答案

【问题标题】：Kafka Connect - How to delete a connectorKafka Connect - 如何删除连接器
【发布时间】：2018-08-03 11:23:03
【问题描述】：

我创建了一个 cassandra-sink 连接器，之后我对connector.properties 文件进行了一些更改。停止工作人员并重新启动后，现在当我使用以下方式添加连接器时：

java -jar kafka-connect-cli-1.0.6-all.jar create cassandra-sink-orders < cassandra-sink-distributed-orders.properties

我收到以下错误：

Error: the Kafka Connect API returned: Connector cassandra-sink-orders already exists (409)

如何删除现有的连接器？

【问题讨论】：

【解决方案1】：

要删除连接器，您可以运行：

curl -X DELETE http://localhost:8083/connectors/<connector-name>

【讨论】：

【解决方案2】：

您可以使用Kafka Connect REST API，其中包括用于DELETE连接器的端点。

curl -X DELETE http://$KAFKACONNECTWORKER_HOST:$KAFKACONNECTWORKER_PORT/connectors/$CONNECTOR_NAME

例如：

curl -X DELETE http://localhost:8083/connectors/src-jdbc-orders

【讨论】：