diff --git a/lib/lepus/consumer.rb b/lib/lepus/consumer.rb
index 7ab1ac3..e89c167 100644
--- a/lib/lepus/consumer.rb
+++ b/lib/lepus/consumer.rb
@@ -104,6 +104,8 @@ def process_delivery(delivery_info, metadata, payload)
           nest_middleware(middleware, next_middleware)
         end
         .call(message)
+    rescue Lepus::InvalidConsumerReturnError
+      raise
     rescue Exception => ex # rubocop:disable Lint/RescueException
       # @TODO: add error handling
       logger.error(ex)