docs: public static Processor<DataSourceTask> source(DataSource source, int parallelism, String description, UserConfig taskConf, ActorSystem system) {
      io.gearpump.streaming.Processor<DataSourceTask<Object, Object>> p =
          DataSourceProcessor.apply(source, parallelism, description, taskConf, system);
      return new Processor(p);
    }