Kafka Connect - 如何删除连接器

Posted 2023-03-10

【中文标题】Kafka Connect - 如何删除连接器

【英文标题】：Kafka Connect - How to delete a connector

【发布时间】：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>

【讨论】：

在我看来这应该是公认的答案。

@DanielBelémDuarte 公平点。我正在编辑我的答案，希望它更有用。

【参考方案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

? 在此处查看实际操作：https://www.youtube.com/watch?v=1EenWEm-5dg&t=378s