在我对 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)
如何移除现有的连接器？
最佳答案
要删除连接器，您可以运行:
curl -X DELETE http://localhost:8083/connectors/<connector-name>
关于apache-kafka - Kafka Connect - 如何删除连接器，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/48947250/