diff --git a/credit-tracker.properties b/credit-tracker.properties
index 7d10cbc..57bae8a 100644
--- a/credit-tracker.properties
+++ b/credit-tracker.properties
@@ -94,7 +94,7 @@ ct.kafka-consumer-settings.concurency=${CONSUMER_CONCURENCY:8}
 ct.kafka-consumer-settings.bootstrap-servers=${CONSUMER_BOOTSTRAP_SERVERS:localhost:29092}
 ct.kafka-consumer-settings.group-id=${CONSUMER_GROUP_ID:credit-tracker}
 ct.kafka-consumer-settings.auto-offset-reset=${CONSUMER_AUTO_OFFSET_RESET:latest}
-ct.kafka-consumer-settings.max-poll-records=${CONSUMER_MAX_POLL_RECORDS:125}
+ct.kafka-consumer-settings.max-poll-records=${CONSUMER_MAX_POLL_RECORDS:500}
 ct.kafka-consumer-settings.max-poll-interval-ms=${CONSUMER_MAX_POLL_INTERVAL_MS:300000}
 
 ct.db-version=${DB_VERSION:1234}
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 91109a9..af64e21 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
@@ -301,8 +301,8 @@ public class SignalKafkaEventWriterService {
 
     private List<SignalKafkaEvent> drain() {
         try {
-            List<SignalKafkaEvent> batch = new ArrayList<>(1000);
-            signalEventsQueue.drainTo(batch, 1000);
+            List<SignalKafkaEvent> batch = new ArrayList<>(8000);
+            signalEventsQueue.drainTo(batch, 8000);
             return batch;
         } catch (Exception e) {
             log.error("Error while drain signal events", e);