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

dbf-exporter доделал опциональный KafkaSender, иначе не запускался без необязательных настроек.

Browse source
This commit is contained in:
AKurakin 2023-02-01 14:48:15 +03:00
parent 8fb186f564
commit 6b43d3b238
1 changed files with 6 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/config/KafkaSenderConfig.java
View file

@ -1,6 +1,8 @@
package ru.spcex.clearing.dbf.exporter.config; package ru.spcex.clearing.dbf.exporter.config;
import org.apache.kafka.clients.producer.Producer; import org.apache.kafka.clients.producer.Producer;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
@ -14,6 +16,7 @@ import ru.spcex.platform.imdg.api.ImdgProvider;
//отдельный конфиг для sender чтобы сделать required false //отдельный конфиг для sender чтобы сделать required false
@Configuration @Configuration
public class KafkaSenderConfig { public class KafkaSenderConfig {
Logger log = LoggerFactory.getLogger(getClass());
private final ImdgProvider imdgProvider; private final ImdgProvider imdgProvider;
private Producer<String, Object> kafkaProducer; private Producer<String, Object> kafkaProducer;
@ -23,14 +26,15 @@ public class KafkaSenderConfig {
this.imdgProvider = imdgProvider; this.imdgProvider = imdgProvider;
} }
@Autowired @Autowired(required = false)
public void setKafkaProducer(Producer<String, Object> kafkaProducer) { public void setKafkaProducer(Producer<String, Object> kafkaProducer) {
this.kafkaProducer = kafkaProducer; this.kafkaProducer = kafkaProducer;
} }
@Bean @Bean
public KafkaSender kafkaSender() { public KafkaSender kafkaSender() {
if (kafkaProducer == null ||imdgProvider == null) { if (kafkaProducer == null || imdgProvider == null) {
log.info("Can not create KafkaSender: kafkaProducer={}, imdgProvider={}", kafkaProducer, imdgProvider);
return null; return null;
} }
ImdgId imdgIdGenerator = imdgProvider.getImdgIdGenerator(); ImdgId imdgIdGenerator = imdgProvider.getImdgIdGenerator();