Kafka Connect - How to delete a connector

apache-kafka apache-kafka-connect
el323 picture el323 · Feb 23, 2018 · Viewed 11.7k times · Source

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?

Answer

foxwendy picture foxwendy · Sep 4, 2018

To delete a connector, you can run:

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

Related questions

Kafka Connect running out of heap space

After starting Kafka Connect (connect-standalone), my task fails immediately after starting with: java.lang.OutOfMemoryError: Java heap space at java.nio.HeapByteBuffer.<init>(HeapByteBuffer.java:57) at java.nio.ByteBuffer.allocate(ByteBuffer.java:335) at org.apache.kafka.common.network.…

Read More
How to connect Kafka with Elasticsearch?

I am new in Kafka, I use kafka to collect netflow through logstash(it is ok), and I want to send the data to elasticsearch from kafka, but there are some problems. My question is how can I connect Kafka …

Read More
How can i get all group list with kafka0.10.x

when i use kafka0.8.x，i can get all group list with zookeeper by path /consumers/group_id, because offsets will commit to zookeeper in 0.8.x. But in version of 0.10.x, offsets commited to kafka broker like a path /brokers/…

Read More