我从日志文件中读取输入并写入kafka。即使在日志旋转之后,inode也不会改变。日志旋转后,仍然读取旋转后的日志文件(xx.log.2020 xx-xx(,而不是指向主文件(xx.log
下面是我为输入文件设置的配置文件。我需要添加任何其他配置来忽略读取旧文件吗。
input {
file {
path => "C:/Users/xx.log"
}
}
这是与此问题相同的问题。默认情况下,Logstash可以很好地处理文件旋转。
你所需要做的就是确保使用一个glob模式(例如...log*
(来识别你的所有日志文件,Logstash会跟踪它们:
input {
file {
path => "C:/Users/xx.log*"
}
}