可以使用flume的interceptor,自己写插件即可,flume的事件模型叫做Event,Event的header部分可以增加主机名,之后做sink的时候,还可以根据header的字段做处理,比如存在hdfs中后,可以根据不同的主机名存放在不同的文件夹。
可以使用flume的interceptor,自己写插件即可,flume的事件模型叫做Event,Event的header部分可以增加主机名,之后做sink的时候,还可以根据header的字段做处理,比如存在hdfs中后,可以根据不同的主机名存放在不同的文件夹。