Flume自定义Source,数据不丢失,一致性,可以根据自己开发情况选择