diff --git a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/config/KafkaConfig.java b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/config/KafkaConfig.java index f0a86b0e6..f1cac72b8 100644 --- a/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/config/KafkaConfig.java +++ b/clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/config/KafkaConfig.java @@ -3,8 +3,10 @@ package ru.spcex.clearing.account.config; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.producer.Producer; import org.springframework.beans.factory.annotation.Autowired; +import org.springframework.beans.factory.config.ConfigurableBeanFactory; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import org.springframework.context.annotation.Scope; import ru.spcex.clearing.account.config.settings.AccountServiceSettings; import ru.spcex.clearing.platform.messaging.config.KafkaConsumerFactory; import ru.spcex.clearing.platform.messaging.config.KafkaProducerFactory; @@ -18,6 +20,7 @@ import ru.spcex.platform.imdg.api.ImdgProvider; @Configuration public class KafkaConfig { @Autowired + @Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE) @Bean public Consumer createConsumer(AccountServiceSettings settings) { return KafkaConsumerFactory.consumer(settings.getKafkaConsumer()); diff --git a/clearing-parent/account-service/src/main/resources/application.properties b/clearing-parent/account-service/src/main/resources/application.properties index f2d6fe4d8..d0d9c873b 100644 --- a/clearing-parent/account-service/src/main/resources/application.properties +++ b/clearing-parent/account-service/src/main/resources/application.properties @@ -2,10 +2,18 @@ spring.main.web-application-type=none account-service.hazelcast.cluster-members=127.0.0.1 account-service.hazelcast.login=dev account-service.hazelcast.password=dev-pass -account-service.kafka.bootstrap-servers=localhost:9092 -account-service.kafka.group-id=dev-group -account-service.kafka.enable-auto-commit=false -account-service.kafka.session-timeout-ms=30000 -account-service.kafka.auto-offset-reset=latest -account-service.kafka.linger-ms=1 -account-service.kafka.buffer-memory=33554432 \ No newline at end of file + +account-service.kafka-consumer.bootstrap-servers=localhost:9092 +account-service.kafka-consumer.group-id=dev-group-account-service +account-service.kafka-consumer.enable-auto-commit=true +account-service.kafka-consumer.session-timeout-ms=30000 +account-service.kafka-consumer.auto-offset-reset=latest +account-service.kafka-consumer.linger-ms=1 +account-service.kafka-consumer.buffer-memory=33554432 + +account-service.kafka-producer.bootstrap-servers=localhost:9092 +account-service.kafka-producer.acks=all +account-service.kafka-producer.retries=0 +account-service.kafka-producer.batch-size=16384 +account-service.kafka-producer.linger-ms=1 +account-service.kafka-producer.buffer-memory=33554432 \ No newline at end of file