日志数据存在elasticsearch中，索引为event_YYYYMMdd，logstash获取数据转发kafka，业务消费有去重机制。