From 8ebf8175dad5fa4df81b809efc9a0d4f36dd9712 Mon Sep 17 00:00:00 2001
From: etreschenkov <etreschenkov>
Date: Wed, 15 Jul 2026 07:59:42 +0300
Subject: [PATCH] Block Kafka event writer on empty queue

---
 .../mode/monitoring/SignalKafkaEventWriterService.java        | 4 ++++
 1 file changed, 4 insertions(+)

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();