连接器状态不一致：ConnectException：此工作人员中已存在任务答案

【问题标题】：Inconsistent connector state: ConnectException: Task already exists in this worker连接器状态不一致：ConnectException：此工作人员中已存在任务
【发布时间】：2017-10-03 18:30:03
【问题描述】：

我正在使用 Confluent Platform 3.2。在 3 台不同的 EC2 机器上运行 3 名工作人员。

我有一个连接器（debezium/MySQL 源），我将其删除并在几分钟后重新启动。但是由于以下错误，我无法成功启动连接器。连接器处于故障状态。我不得不重新启动工作人员来解决问题。

需要知道这是否是缓存问题？如何在不重新启动工作人员的情况下解决此问题。感谢任何支持。

   {
   "name": "debezium-connector",
   "connector": {
      "state": "RUNNING",
      "worker_id": "xx.xx.xx.xxx:8083"
   },
   "tasks": [
      {
         "state": "FAILED",
         "trace": "org.apache.kafka.connect.errors.ConnectException: Task already exists in this worker: debezium-connector-0\n\tat org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:308)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:834)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$1500(DistributedHerder.java:101)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:848)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:844)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\n\tat java.lang.Thread.run(Thread.java:745)\n",
         "id": 0,
         "worker_id": "xx.xx.xx.xxx:8083"
      }
   ]
}

【问题讨论】：

另一个连接器出现同样的问题。
issues.apache.org/jira/browse/KAFKA-7878?尝试添加不同名称的任务

标签： apache-kafka apache-kafka-connect confluent-platform debezium

【解决方案1】：

嗯。我遇到了同样的错误，然后我发现其中一台 Kafka 服务器的磁盘空间不足，因此 Kafka 集群无法正常运行。不知道这里的所有细节，但我希望 Connect 会在 Kafka 中存储一些关于连接器和任务的信息，如果它没有正确响应，Kafka 仍然可以有关于旧任务的信息。

分享以防万一。

编辑：

我还注意到，this issue 不时发生在我的 Kafka 节点上，导致整个集群处于不可用状态。重启有问题的节点可以解决问题。

【讨论】：