diff --git a/internal/pubsub/subscriber.go b/internal/pubsub/subscriber.go index bb2ec6f..d4642fa 100644 --- a/internal/pubsub/subscriber.go +++ b/internal/pubsub/subscriber.go @@ -110,10 +110,8 @@ func (s Subscriber) listen(messages <-chan *message.Message, wg *sync.WaitGroup) if err := s.processEvent(msg); err != nil { s.logger.Warn("Failed to process msg: ", err) - s.logger.Infow("message nacked", "event.id", msg.UUID) msg.Nack() } else { - s.logger.Infow("message acked", "event.id", msg.UUID) msg.Ack() } }