找不到tombstonehandler类

bq9c1y66  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(323)

我有一个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

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题