目前kafka消费日志志存入当前时间段es index。 该pr修改为kafka消费日志存入日志对应时间段es index。
git checkout master
git pull https://gitee.com/galaxist/plumelog.git master
git push origin master
