Browse Source

File acquisition: log "file reopen" events instead of writing to stderr (#2139)

mmetc 2 years ago
parent
commit
d769fff1e8
1 changed files with 1 additions and 1 deletions
  1. 1 1
      pkg/acquisition/modules/file/file.go

+ 1 - 1
pkg/acquisition/modules/file/file.go

@@ -310,7 +310,7 @@ func (f *FileSource) StreamingAcquisition(out chan types.Event, t *tomb.Tomb) er
 			continue
 			continue
 		}
 		}
 
 
-		tail, err := tail.TailFile(file, tail.Config{ReOpen: true, Follow: true, Poll: true, Location: &tail.SeekInfo{Offset: 0, Whence: io.SeekEnd}})
+		tail, err := tail.TailFile(file, tail.Config{ReOpen: true, Follow: true, Poll: true, Location: &tail.SeekInfo{Offset: 0, Whence: io.SeekEnd}, Logger: log.NewEntry(log.StandardLogger())})
 		if err != nil {
 		if err != nil {
 			f.logger.Errorf("Could not start tailing file %s : %s", file, err)
 			f.logger.Errorf("Could not start tailing file %s : %s", file, err)
 			continue
 			continue