#可以看到一条数据按规则被解析成了两条
{"active_time":18989989,"user_id":"197878787878787","item_type":"clothes","host":"www.baidu.com"}
{"active_time":18989989,"user_id":"197878787878787","item_type":"car","host":"www.baidu.com"}
自定义拦截器要点
A、实现Interceptor接口中intercept(Event event)方法和intercept(List<Event> events)方法。
B、创建内部类Builder实现Interceptor.Builder接口。
C、注意对异常数据的处理。防止Agent奔溃。
���结
通过拦截器确实实现了这一功能，为解决这一类问题提供了一种很好的思路，但逻辑太过复杂反而会降低flume同步效率，生产环境下还要多加验证。
Linux公社的RSS地址：https://www.linuxidc.com/rssFeed.aspx