kafka hdfs连接器java空指针异常

zf9nrax1 于 2021-06-06 发布在 Kafka

关注(0)|答案(0)|浏览(167)

我正在尝试将kafka连接到hdfs，但在运行配置时，出现以下错误：

java.lang.NullPointerException
at io.confluent.connect.hdfs.HdfsSinkTask.close(HdfsSinkTask.java:121)
at org.apache.kafka.connect.runtime.WorkerSinkTask.commitOffsets(WorkerSinkTask.java:339)
at org.apache.kafka.connect.runtime.WorkerSinkTask.closePartitions(WorkerSinkTask.java:513)
at org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:154)
at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:146)
at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:190)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)

我正在landoop web ui上运行任务：

有人知道这个错误是从哪里来的吗？谢谢