这里以按自定义头部的配置为例（依据某些业务不同写入不同的主目录）
配置：
source:
interceptors = i1 interceptors.i1.type = regex_extractor interceptors.i1.regex = /apps/logs/(.*?)/ interceptors.i1.serializers = s1 interceptors.i1.serializers.s1.name = logtypenameinter
阅读背景：
HDFSEventSink目录设置功能实现源码分析
来源：互联网
分享到：
