方案一

1、扫描数据表，过滤当前时间-数据表任务时间 < duration的时间

2、如果过滤后有记录，发送一个管道通知

3、一个gouroutine接收通知，扫描指定目录，发送kafka消息

方案二

1、扫描数据表，通过数据表字段内容拼出crontab的spec

2、动态的增加、删除job工作

3、通过维护一张hash表，key为spec, value为addJob的增长ID

4、扫描制定目录、发送kafka消息

采用第一种方案

使用go扩展包

数据库    "github.com/tidwall/buntdb"
定时任务   "github.com/robfig/cron/v3"
配置文件   "gopkg.in/ini.v1"
kafka    "probe/pkg/kafka"