add log

TelkomIndonesia · Nov 20, 2023 · 9d7ea16 · 9d7ea16
1 parent 08f3cc7
commit 9d7ea16
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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
 }