if (annotateFileName) {
String filename = currentFile.get().getFile().getAbsolutePath();
for (Event event : events) {
event.getHeaders().put(fileNameHeader, filename);
}
}
这是该源类型的特定实现细节。如果要保留原始文件名,则需要设置属性,以下是可用选项:
fileHeader false Whether to add a header storing the absolute path filename.
fileHeaderKey file Header key to use when appending absolute path filename to event header.
1条答案
按热度按时间dba5bblo1#
文件名在spool源实现中设置:
这是该源类型的特定实现细节。如果要保留原始文件名,则需要设置属性,以下是可用选项:
如果要添加时间戳,实际上可以使用内置拦截器:
时间戳拦截器
flume示例主机名的主机侦听器
任何常量值的staticinterceptor。