diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java
index c7c78d5fa..7dcbd75a6 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/Clearing.java
@@ -188,6 +188,8 @@ public class Clearing {
                     //обновлен, и была проблема была с сетью/недоступностью кафки etc.
                 } catch (InterruptedException e) {
                     log.error(ExceptionUtils.getStackTrace(e));
+                    Thread.currentThread().interrupt();
+                    throw new RuntimeException(e);
                 }
                 if (!Objects.equals(lastAccBalanceResponseId, sentRequestId)) {
                     log.error("FATAL: last response from AccountBalance update from Kafka ID was {}, but sent ID was {}",
diff --git a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java
index 0dc6ac3b9..66f61dfa0 100644
--- a/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java
+++ b/clearing-parent/clearing-service/src/main/java/ru/spcex/clearing/service/ClearingService.java
@@ -90,6 +90,7 @@ public class ClearingService implements DisposableBean {
     public void continueClearing(BaseRequest<CommonIdRequest> event) {
         synchronized (clearing) {
             CommonIdRequest requestPayload = event.getRequestPayload();
+            log.debug("continueClearing for id={}", requestPayload.getId());
             clearing.setLastAccBalanceResponseId(requestPayload.getId());
             clearing.notifyAll();
         }