Kafka Connect - 如何删除连接器
Kafka Connect - How to delete a connector
我在 connector.properties 文件中做了一些更改之后创建了一个 cassandra-sink 连接器。在停止工作人员并重新启动它之后，现在当我使用以下方式添加连接器时：
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)
如何删除现有连接器？
您可以使用 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
要删除连接器，您可以运行:
curl -X DELETE http://localhost:8083/connectors/<connector-name>
我在 connector.properties 文件中做了一些更改之后创建了一个 cassandra-sink 连接器。在停止工作人员并重新启动它之后，现在当我使用以下方式添加连接器时：
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)
如何删除现有连接器？
您可以使用 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
要删除连接器，您可以运行:
curl -X DELETE http://localhost:8083/connectors/<connector-name>