org.apache.kafka.connect.errors.ConnectException：此工作人员中已存在任务

【问题标题】：org.apache.kafka.connect.errors.ConnectException: Task already exists in this workerorg.apache.kafka.connect.errors.ConnectException：此工作人员中已存在任务
【发布时间】：2018-11-18 06:55:01
【问题描述】：

如何解决这个问题？

org.apache.kafka.connect.errors.ConnectException: 任务已经存在于这个worker中

我们已经在单个服务器上设置了 kafka 和 kafka-connect，我所有的连接器都出现了上述错误。

在重新启动连接服务后，所有工作人员都卡在未分配模式。

【问题讨论】：

您要使用哪个连接器？你在哪里看到的？在连接器的/status 端点中还是在您发布配置时？你能检查一下你在服务器上的工作日志吗？此外，这里并不重要，但理想情况下，Kafka Connect 不应与代理运行在同一台机器上（您不会在代理上运行其他消费者/生产者）

标签： apache-kafka apache-kafka-connect

【解决方案1】：

我自己也遇到了这个错误，并设法通过 SSH 连接到报告错误的连接服务器来修复它，停止所有正在运行的 Kafka Connect 实例，例如sudo systemctl stop kafka-connect，或者SIGTERM它

# 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 连接器配置。

【讨论】：