diff --git a/src/main/java/ru/nbch/credit_tracker/service/mode/monitoring/SignalKafkaEventWriterService.java b/src/main/java/ru/nbch/credit_tracker/service/mode/monitoring/SignalKafkaEventWriterService.java
index e46932c..a17be1e 100644
--- a/src/main/java/ru/nbch/credit_tracker/service/mode/monitoring/SignalKafkaEventWriterService.java
+++ b/src/main/java/ru/nbch/credit_tracker/service/mode/monitoring/SignalKafkaEventWriterService.java
@@ -321,8 +321,12 @@ public class SignalKafkaEventWriterService {
     private List<SignalKafkaEvent> drain() {
         try {
             List<SignalKafkaEvent> batch = new ArrayList<>(8000);
+            batch.add(signalEventsQueue.take());
             signalEventsQueue.drainTo(batch, 8000);
             return batch;
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+            return Collections.emptyList();
         } catch (Exception e) {
             log.error("Error while drain signal events", e);
             return Collections.emptyList();