我创建了一个cassandra-sink连接器,之后我在connector.properties
文件中做了一些修改。在停止worker并再次启动它之后,现在当我使用以下命令添加连接器时:
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)
如何删除现有的连接器?
发布于 2018-02-23 12:26:43
您可以使用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
发布于 2018-09-04 18:30:35
要删除连接器,可以运行以下命令:
curl -X DELETE http://localhost:8083/connectors/<connector-name>
https://stackoverflow.com/questions/48947250
复制