From 9d7ea1654c3a429a205bd623ec0e62cc72f0b098 Mon Sep 17 00:00:00 2001 From: Rucciva Date: Mon, 20 Nov 2023 09:20:43 +0700 Subject: [PATCH] add log --- stream.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/stream.go b/stream.go index 03ffba9..c1d4744 100644 --- a/stream.go +++ b/stream.go @@ -228,5 +228,9 @@ func (s *Logstream) SkiptoCatchUp(maxlag time.Duration) { if now.Sub(s.start) <= maxlag { return } - s.start = now.Add(-maxlag) + + newStart := now.Add(-maxlag) + log.Printf("[WARN] logs of '%s''%s' from '%s' to '%s' will be skipped .\n", + s.group.LogGroupName, s.stream.LogStreamName, s.start, newStart) + s.start = newStart }