Skip to content

Commit

Permalink
lower log level for expired/lost messages
Browse files Browse the repository at this point in the history
  • Loading branch information
weeco committed Apr 5, 2024
1 parent a50eaf7 commit 2bc1ad7
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion e2e/message_tracker.go
Original file line number Diff line number Diff line change
Expand Up @@ -129,7 +129,7 @@ func (t *messageTracker) onMessageExpired(_ string, reason ttlcache.EvictionReas
age := time.Since(created)
t.svc.lostMessages.WithLabelValues(strconv.Itoa(msg.partition)).Inc()

t.logger.Info("message expired/lost",
t.logger.Debug("message expired/lost",
zap.Int64("age_ms", age.Milliseconds()),
zap.Int("partition", msg.partition),
zap.String("message_id", msg.MessageID),
Expand Down

0 comments on commit 2bc1ad7

Please sign in to comment.