diff --git a/kombu/message.py b/kombu/message.py
index a4d7e2d4..bcc90d1a 100644
--- a/kombu/message.py
+++ b/kombu/message.py
@@ -126,6 +126,10 @@ class Message:
     def ack_log_error(self, logger, errors, multiple=False):
         try:
             self.ack(multiple=multiple)
+        except BrokenPipeError as exc:
+            logger.critical("Couldn't ack %r, reason:%r",
+                            self.delivery_tag, exc, exc_info=True)
+            raise
         except errors as exc:
             logger.critical("Couldn't ack %r, reason:%r",
                             self.delivery_tag, exc, exc_info=True)