treshenkov/credit_tracker
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Block Kafka event writer on empty queue

Browse source
This commit is contained in:
etreschenkov 2026-07-15 07:59:42 +03:00
parent 9e7c084712
commit 8ebf8175da
1 changed files with 4 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/main/java/ru/nbch/credit_tracker/service/mode/monitoring/SignalKafkaEventWriterService.java
View file

@ -321,8 +321,12 @@ public class SignalKafkaEventWriterService {
private List<SignalKafkaEvent> drain() { private List<SignalKafkaEvent> drain() {
try { try {
List<SignalKafkaEvent> batch = new ArrayList<>(8000); List<SignalKafkaEvent> batch = new ArrayList<>(8000);
batch.add(signalEventsQueue.take());
signalEventsQueue.drainTo(batch, 8000); signalEventsQueue.drainTo(batch, 8000);
return batch; return batch;
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
return Collections.emptyList();
} catch (Exception e) { } catch (Exception e) {
log.error("Error while drain signal events", e); log.error("Error while drain signal events", e);
return Collections.emptyList(); return Collections.emptyList();