diff --git a/internal/nats/sub.go b/internal/nats/sub.go
index c020c30..2d42e3c 100644
--- a/internal/nats/sub.go
+++ b/internal/nats/sub.go
@@ -45,7 +45,11 @@ func Subscribe(config *config.Config, marshaler *handlers.PlainTextMarshaler, ha
 	}
 
 	for msg := range messages {
-		handler.HandleMessage(msg)
-		msg.Ack()
+		if err := handler.HandleMessage(msg); err == nil {
+			msg.Ack()
+		} else {
+			logger.Error("Failed to handle message", err, map[string]interface{}{"message": msg})
+			msg.Nack()
+		}
 	}
 }