小编Fra*_*sco的帖子

卡夫卡连接:“此工作程序中已存在任务”

我看到了我的连接器的状态,但我有这个例外

org.apache.kafka.connect.errors.ConnectException: Task already exists in this worker: *name of the connector*
        at org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:365)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:857)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$1600(DistributedHerder.java:109)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:871)
        at org.apache.kafka.connect.runtime.distributed.DistributedHerder$13.call(DistributedHerder.java:867)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)
Run Code Online (Sandbox Code Playgroud)

当我执行curl -s ip:8081/connectors/name of connector/tasks命令查看连接器的任务列表时,我得到了这个结果

{"error_code":404,"message":"HTTP 404 Not Found"}
Run Code Online (Sandbox Code Playgroud)

我不知道它是什么。谢谢

apache-kafka apache-kafka-connect

5
推荐指数
1
解决办法
1401
查看次数

标签 统计

apache-kafka ×1

apache-kafka-connect ×1