CODEWITHSUNDEEP
apache-kafkaapache-kafka-connect
el323
el323

Reputation: 2920

Kafka Connect - How to delete a connector

I created a cassandra-sink connector after that I made some changes in connector.properties file. After stopping the worker and starting it again, now when I add the connector using:

java -jar kafka-connect-cli-1.0.6-all.jar create cassandra-sink-orders < cassandra-sink-distributed-orders.properties

I get the following error:

Error: the Kafka Connect API returned: Connector cassandra-sink-orders already exists (409)

How can I remove the existing connector?

Upvotes: 23

Views: 39229

Answers (2)

Robin Moffatt
Robin Moffatt

Reputation: 32110

You can use the Kafka Connect REST API, which includes an endpoint for DELETEing a connector.

curl -X DELETE http://$KAFKACONNECTWORKER_HOST:$KAFKACONNECTWORKER_PORT/connectors/$CONNECTOR_NAME

For example:

curl -X DELETE http://localhost:8083/connectors/src-jdbc-orders

🎥 See it in action here: https://www.youtube.com/watch?v=1EenWEm-5dg&t=378s

Upvotes: 13

foxwendy
foxwendy

Reputation: 2929

To delete a connector, you can run:

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

Upvotes: 64

Related Questions