flume custom regex interceptor
水槽自定义正则表达式拦截器简单拦截器,它是 Flume 正则表达式过滤器拦截器的扩展。使用时,可以指定需要从事件 body 中拉出以发送到 Channel/Sink 的字段列表。添加了一个名为 indexSelector 的新文件 agent.sources.agent_name.interceptors.filter_name.regex=INFO(.*)Python(.*)Test(.*)
,agent.sources.agent_name.interceptors.filter_name.indexSelector=1,2
。1,2 将拉取正则表达式匹配字符串的前2个字段。
下载地址
用户评论