diff --git a/common/ASC.Common/Caching/KafkaCache.cs b/common/ASC.Common/Caching/KafkaCache.cs
index d0c6645d47..410b9c18fb 100644
--- a/common/ASC.Common/Caching/KafkaCache.cs
+++ b/common/ASC.Common/Caching/KafkaCache.cs
@@ -125,7 +125,14 @@ namespace ASC.Common.Caching
                             var cr = c.Consume(Cts[channelName].Token);
                             if (cr != null && cr.Value != null && !(new Guid(cr.Key.Id.ToByteArray())).Equals(Key) && Actions.TryGetValue(channelName, out var act))
                             {
-                                act(cr.Value);
+                                try
+                                {
+                                    act(cr.Value);
+                                }
+                                catch (Exception e)
+                                {
+                                    Log.Error("Kafka onmessage", e);
+                                }
                             }
                         }
                         catch (ConsumeException e)