diff --git a/application/src/main/java/org/thingsboard/server/service/edge/rpc/KafkaEdgeGrpcSession.java b/application/src/main/java/org/thingsboard/server/service/edge/rpc/KafkaEdgeGrpcSession.java
index e9a33520ad..a65e6ab85f 100644
--- a/application/src/main/java/org/thingsboard/server/service/edge/rpc/KafkaEdgeGrpcSession.java
+++ b/application/src/main/java/org/thingsboard/server/service/edge/rpc/KafkaEdgeGrpcSession.java
@@ -116,6 +116,7 @@ public class KafkaEdgeGrpcSession extends AbstractEdgeGrpcSession {
     public void processHighPriorityEvents() {
         isHighPriorityProcessing = true;
         super.processHighPriorityEvents();
+        isHighPriorityProcessing = false;
     }
 
     @Override