diff --git a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/message/BrokerApiSubscribers.java b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/message/BrokerApiSubscribers.java
index ac4a972..ed80334 100644
--- a/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/message/BrokerApiSubscribers.java
+++ b/src/main/java/com/googlesource/gerrit/plugins/rabbitmq/message/BrokerApiSubscribers.java
@@ -77,7 +77,13 @@
                   topic, messageBody);
               Event event = deserializeWithRetry(messageBody);
               if (event.type != null) {
-                topicSubscriber.consumer().accept(event);
+                try {
+                  topicSubscriber.consumer().accept(event);
+                } catch (Exception e) {
+                  logger.atWarning().withCause(e).log(
+                      "Consumer listening on topic %s threw an exception for data: %s",
+                      topic, messageBody);
+                }
               } else {
                 logger.atFine().log("Event does not have a type, ignoring Event");
               }