创建采集任务
消费
WEB
异步通知运行采集任务(Redis publish)
构造reader/writer执行采集任务
写入
Elasticsearch
PluginService.runSchedule
JDBCReaderExcelReaderRequestReader。。。。。。
Disruptor高速队列
Other...
单次或周期运行任务
Kafka
离线数据文件
importor服务
DataSourceService.run
ElasticSearchWriter
