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

http://jira.mfd.msk:8088/browse/CLS-36

Browse source
This commit is contained in:
ialbert 2022-09-28 19:12:03 +03:00
parent 15cad890c9
commit 66cbf4e6b2
2 changed files with 18 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
clearing-parent/account-service/src/main/java/ru/spcex/clearing/account/config/KafkaConfig.java
View file

@ -3,8 +3,10 @@ package ru.spcex.clearing.account.config;
import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.Consumer;
import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.Producer;
import org.springframework.beans.factory.annotation.Autowired; 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.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Scope;
import ru.spcex.clearing.account.config.settings.AccountServiceSettings; import ru.spcex.clearing.account.config.settings.AccountServiceSettings;
import ru.spcex.clearing.platform.messaging.config.KafkaConsumerFactory; import ru.spcex.clearing.platform.messaging.config.KafkaConsumerFactory;
import ru.spcex.clearing.platform.messaging.config.KafkaProducerFactory; import ru.spcex.clearing.platform.messaging.config.KafkaProducerFactory;
@ -18,6 +20,7 @@ import ru.spcex.platform.imdg.api.ImdgProvider;
@Configuration @Configuration
public class KafkaConfig { public class KafkaConfig {
@Autowired @Autowired
@Scope(ConfigurableBeanFactory.SCOPE_PROTOTYPE)
@Bean @Bean
public Consumer<String, Object> createConsumer(AccountServiceSettings settings) { public Consumer<String, Object> createConsumer(AccountServiceSettings settings) {
return KafkaConsumerFactory.consumer(settings.getKafkaConsumer()); return KafkaConsumerFactory.consumer(settings.getKafkaConsumer());

22
clearing-parent/account-service/src/main/resources/application.properties
View file

@ -2,10 +2,18 @@ spring.main.web-application-type=none
account-service.hazelcast.cluster-members=127.0.0.1 account-service.hazelcast.cluster-members=127.0.0.1
account-service.hazelcast.login=dev account-service.hazelcast.login=dev
account-service.hazelcast.password=dev-pass account-service.hazelcast.password=dev-pass
account-service.kafka.bootstrap-servers=localhost:9092
account-service.kafka.group-id=dev-group account-service.kafka-consumer.bootstrap-servers=localhost:9092
account-service.kafka.enable-auto-commit=false account-service.kafka-consumer.group-id=dev-group-account-service
account-service.kafka.session-timeout-ms=30000 account-service.kafka-consumer.enable-auto-commit=true
account-service.kafka.auto-offset-reset=latest account-service.kafka-consumer.session-timeout-ms=30000
account-service.kafka.linger-ms=1 account-service.kafka-consumer.auto-offset-reset=latest
account-service.kafka.buffer-memory=33554432 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