Kafka Connect - 如何删除连接器

Question

之后我创建了一个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)

如何删除现有连接器？

Answer 1

要删除连接器,您可以运行:

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

Answer 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

这可能是故意的，但对我来说这是违反直觉的，当您删除连接器并发布具有相同名称的连接器时，它会在某种程度上重新使用旧配置。例如，我有一个损坏的 Debezium 连接器，其二进制日志偏移量已不存在。我删除了它，然后再次创建了它，认为它会从它能找到的第一个二进制日志开始，但它以相同的损坏偏移量开始。 (2认同)