org.apache.kafka.connect.errors.ConnectException: задача в этом работнике уже существует

Question

Как это исправить?

org.apache.kafka.connect.errors.ConnectException: в этом работнике уже существует задача

Мы настроили kafka и kafka-connect на одном сервере и всемой разъем выдаёт вышеуказанную ошибку.

Кроме того, после перезапуска службы подключения все рабочие застряли в неназначенном режиме.

Answer 1

Я только что сам получил эту ошибку и смог исправить ее, выполнив SSH-соединение с сервером Connect, сообщившим об ошибке, остановив все запущенные экземпляры Kafka Connect, например sudo systemctl stop kafka-connect или SIGTERM it

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

Затем снова запустите его с помощью systemctl start kafka-connect или connect-distributed

В качестве альтернативы, вы также можете попробовать HTTP DELETE & re- POST коннектор конфигурации.