diff --git a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
index f6623b62a3..fd5a252cc5 100644
--- a/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
+++ b/application/src/main/java/org/thingsboard/server/service/queue/DefaultTbCoreConsumerService.java
@@ -667,7 +667,8 @@ public class DefaultTbCoreConsumerService extends AbstractConsumerService<ToCore
     private void forwardToEventService(Event event, TbCallback callback) {
         DonAsynchron.withCallback(actorContext.getEventService().saveAsync(event),
                 result -> callback.onSuccess(),
-                callback::onFailure);
+                callback::onFailure,
+                actorContext.getDbCallbackExecutor());
     }
 
     private void throwNotHandled(Object msg, TbCallback callback) {