Apache Ignite连接器-提供NoClassDefFoundError

Question

我正试图在Apache ignite Sink连接器的帮助下将kafka主题数据加载到ignite缓存中。面临以下问题。所有必需的JAR以及ignite配置(xml)文件都已就绪。

我很不确定为什么它要为IGniteSinkTask$StreamerContext$Holder抛出ConnectException和NoClassDefoundException。由于某些原因，java无法运行这些类。

public static class StreamerContext {
    private StreamerContext() {
    }

    public static Ignite getIgnite() {
        return IgniteSinkTask.StreamerContext.Holder.IGNITE;
    }

    public static IgniteDataStreamer getStreamer() {
        return IgniteSinkTask.StreamerContext.Holder.STREAMER;
    }

    private static class Holder {
        private static final Ignite IGNITE;
        private static final IgniteDataStreamer STREAMER;

        private Holder() {
        }

        static {
            IGNITE = Ignition.start(IgniteSinkTask.igniteConfigFile);
            STREAMER = IGNITE.dataStreamer(IgniteSinkTask.cacheName);
        }
    }
}

我如何解决这个问题？提前谢了。

[ERROR]2021-08-27 06:13:58,827[task-thread-IgniteSinkConnectorConnector_0-0]org.apache.kafka.connect.runtime.WorkerSinkTask DeliverMessages-workersinkTask{id=ignitesinkconnectorconnector_0-0}任务引发了一个未捕获且不可恢复的异常。任务正在被终止，并且在手动重新启动之前不会恢复。错误：无法初始化类org.apache.ignite.stream.kafka.connect.ignitesinktask$streamercontext$holder：无法初始化类org.apache.ignite.stream.kafka.connect.runtime.workersinn的org.apache.ignite.stream.kafka.stream.kafka.runtime.workersinn deliverMessages（workersinktask.java：586）在org.apache.kafka.connect.runtime.workersinktask.poll（workersinktask.java：329）在org.apache.kafka.connect.runtime.workersinktask.iteration（workersinktask.java：232）在org.apache.kafka.connect.runtime.workersinktask.java：232）在在java.base/java.util.concurrent.executors$runnableadapter.call（Exe）处的kafka.connect.runtime.workertask.run（workertask.java:234)cutors.java:515)在java.base/java.util.concurrent.futureTask.run(FutureTask.java:264)在java.base/java.util.concurrent.threadPoolExecutor.runworker(threadPoolExecutor.java:1128)在java.base/java.util.concurrent.threadPoolExecutor.java:1128)在java.base/java.util.concurrent.threadPoolExecutor$worker.run time.workerTask doRun-WorkerSinkTask{id=ignitesinkconnectorconnector_0-0}任务引发了一个未捕获且不可恢复的异常。任务正在被杀死，直到手动重新启动org.apache.kafka.connect.errors.connectException：由于不可恢复的异常正在退出WorkerSinkTask。在org.apache.kafka.connect.runtime.WorkerSinkTask.delivermessages（WorkerSinkTask.java:614)在e.WorkerSinkTask.iteration(WorkerSinkTask.java:232)位于org.apache.kafka.connect.runtime.workersinktask.execute(workersinktask.java:201)在org.apache.kafka.connect.runtime.workertask.dorun（workertask.java:185)在org.apache.kafka.connect.runtime.workertask.run（workertask.java:185)在java.base/java.util.concurrent.executors$runnableadapter.call（在java.base/java.util.concurrent.threadpoolexecutor.worker(threadpoolexecutor.java:1128)在java.base/java.lang.thread.run（threadpoolexecutor.javer.run（threadpoolexecutor.java:628)在java.base/java.lang.thread.run（threadpoolexecutor.javer.run（threadpoolexecutor.java:834)在java.base/java.lang.thread：.kafka.connect.ignitesinktask.put（ignitesinktask.java:118)在org.apache.kafka.connect.runtime.workersInkTask.DeliverMessages(workersInkTask.java:586)

Answer 1

如果Java虚拟机或ClassLoader实例试图加载类的定义（作为普通方法调用的一部分或作为使用新表达式创建新实例的一部分），但找不到该类的定义，则抛出NoClassDefFoundError。编译当前正在执行的类时已存在搜索的类定义，但再也找不到该定义。简单地说，该类在编译时可用，但在运行时丢失。

有关进一步调试，请参阅以下内容：