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

Increase batch

Browse source
This commit is contained in:
Mikhail Trofimov 2026-06-30 12:25:47 +03:00
parent ecbea33a7e
commit 50b8eeee89
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
credit-tracker.properties
View file

@ -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.bootstrap-servers=${CONSUMER_BOOTSTRAP_SERVERS:localhost:29092}
ct.kafka-consumer-settings.group-id=${CONSUMER_GROUP_ID:credit-tracker} 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.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.kafka-consumer-settings.max-poll-interval-ms=${CONSUMER_MAX_POLL_INTERVAL_MS:300000}
ct.db-version=${DB_VERSION:1234} ct.db-version=${DB_VERSION:1234}

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

@ -301,8 +301,8 @@ public class SignalKafkaEventWriterService {
private List<SignalKafkaEvent> drain() { private List<SignalKafkaEvent> drain() {
try { try {
List<SignalKafkaEvent> batch = new ArrayList<>(1000); List<SignalKafkaEvent> batch = new ArrayList<>(8000);
signalEventsQueue.drainTo(batch, 1000); signalEventsQueue.drainTo(batch, 8000);
return batch; return batch;
} catch (Exception e) { } catch (Exception e) {
log.error("Error while drain signal events", e); log.error("Error while drain signal events", e);