CODEWITHSUNDEEP
apache-kafkaapache-kafka-connect
Raghav salotra
Raghav salotra

Reputation: 870

org.apache.kafka.connect.errors.ConnectException: Task already exists in this worker

How to fix this?

org.apache.kafka.connect.errors.ConnectException: Task already exists in this worker

We have set up kafka and kafka-connect on single server and all my connector are giving above error.

Also after restarting the connect service all the workers are stuck in unassigned mode.

Upvotes: 0

Views: 814

Answers (1)

OneCricketeer
OneCricketeer

Reputation: 191748

I just had this error myself and mananged to fix it by SSH-ing to the Connect server reporting the error, stopping all running instances of Kafka Connect e.g. sudo systemctl stop kafka-connect, or SIGTERM it

# ps -ef | grep java | grep Connect | grep -v grep | awk '{print $2}'
<id>
# kill <id>

Then start it back up via systemctl start kafka-connect, or connect-distributed

Alternatively, you could also try HTTP DELETE & re-POST the connector config.

Upvotes: 1

Related Questions