我有一个hdfssink连接器,它与分布式kafka连接器一起工作,有两个任务。其中一个失败,下面是失败状态:
{
"id": 1,
"state": "FAILED",
"worker_id": "X.X.X.X:8083",
"trace": "org.apache.kafka.common.config.ConfigException: Invalid value io.confluent.connect.transforms.TombstoneHandler for configuration transforms.tombstoneHandler.type: Class io.confluent.connect.transforms.TombstoneHandler could not be found.\n\tat org.apache.kafka.common.config.ConfigDef.parseType(ConfigDef.java:720)\n\tat org.apache.kafka.connect.runtime.ConnectorConfig.enrich(ConnectorConfig.java:308)\n\tat org.apache.kafka.connect.runtime.ConnectorConfig.<init>(ConnectorConfig.java:212)\n\tat org.apache.kafka.connect.runtime.ConnectorConfig.<init>(ConnectorConfig.java:206)\n\tat org.apache.kafka.connect.runtime.Worker.startTask(Worker.java:421)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.startTask(DistributedHerder.java:1036)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.access$1600(DistributedHerder.java:117)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder$12.call(DistributedHerder.java:835)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder$12.call(DistributedHerder.java:816)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.tick(DistributedHerder.java:296)\n\tat org.apache.kafka.connect.runtime.distributed.DistributedHerder.run(DistributedHerder.java:245)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)\n\tat java.lang.Thread.run(Thread.java:748)\n"
}
当我用这个命令安装带有合流集线器的tombstonehandler时,就会发生这种情况:
confluent-hub install confluentinc/connect-transforms:latest
暂无答案!
目前还没有任何答案,快来回答吧!