kafka-connect插件在maintainTaskState时候，因为类加载器问题导致run不起来


如图画框的部分，Future future = taskExecutor.submit(workerSourceTask); 提交到线程池后，此时线程池的类加载器是AppclassLoader,而不是pluginClassLoader，会导致WorkerSourceTask 的run方法中在启动kafkaconsumer时候报错，我报的时候加载key和value的反序列化类错误了。这个类得用pluginClassLoader加载而不能用appClassLoader加载。