fix logging

This commit is contained in:
chrislu
2022-01-10 01:00:11 -08:00
parent cbc055dc2b
commit 6a12520a96
2 changed files with 5 additions and 2 deletions

View File

@@ -84,11 +84,11 @@ func AddOffsetFunc(processEventFn ProcessMetadataFunc, offsetInterval time.Durat
}
counter++
if lastWriteTime.Add(offsetInterval).Before(time.Now()) {
counter = 0
lastWriteTime = time.Now()
if err := offsetFunc(counter, resp.TsNs); err != nil {
return err
}
counter = 0
}
return nil
}