🔥码云GVP开源项目 12k star Uniapp+ElementUI 功能强大 支持多语言、二开方便! 广告
拦截器也是通过命名配置的组件,下面是通过配置文件创建拦截器的例子。 ```conf ############## 1. Agent初始化 ############ # agent为Agent的名字,可以随便命名 # s1、c1、sk1是在该agent下的Source、Channel、Sink,也可以随便命名 agent.sources = s1 agent.channels = c1 agent.sinks = sk1 ########## 拦截器配置 ################ agent.sources.s1.interceptors = i1 i2 agent.sources.s1.interceptors.il.type = org.apache.flume.interceptor.HostInterceptor$Builder # 如果 header 中已经存在同名的属性是否保留 agent.sources.s1.interceptors.il.preserveExisting = false # 向 Event header 中添加 host 键值对的 key agent.sources.s1.interceptors.il.hostHeader = hostname # 这个拦截器会向每个 Event 的 header 中添加一个时间戳属性进去,key 默认是timestamp agent.sources.s1.interceptors.i2.type = org.apache.flume.interceptor.TimestampInterceptor$Builder agent.sinks.sk1.filePrefix = FlumeData.%{CollectorHost}.%Y-%m-%d ############## 2. Source配置 ############# # 指定Source类型、主机、端口号(与上面的sink端口号相同)、通道 agent.sources.s1.type = avro agent.sources.s1.bind = hadoop101 agent.sources.s1.port = 4444 agent.sources.s1.channels = c1 ############ 3. Channel配置 ############ # 指定Channel类型 agent.channels.c1.type = memory ############ 4. Sink配置 ############# # 指定sink类型、通道 agent.sinks.sk1.type = logger agent.sinks.sk1.channel = c1 ```