diff --git a/consumer.go b/consumer.go index 3b7aa33..b024fcb 100644 --- a/consumer.go +++ b/consumer.go @@ -65,7 +65,7 @@ loop: if err != nil { if errors.Is(err, context.Canceled) { // Suppress expected errors during shutdown - zap.S().Info("ReceiveMessage interrupted due to context cancellation") + zap.S().Warn("ReceiveMessage interrupted due to context cancellation") continue } zap.S().With(zap.Error(err)).Error("could not receive messages from SQS")