From 6b43d3b238245d7b4460b1095f85a2913e5f945e Mon Sep 17 00:00:00 2001
From: AKurakin <akurakin@mfd.ru>
Date: Wed, 1 Feb 2023 14:48:15 +0300
Subject: [PATCH] =?UTF-8?q?dbf-exporter=20=D0=B4=D0=BE=D0=B4=D0=B5=D0=BB?=
 =?UTF-8?q?=D0=B0=D0=BB=20=D0=BE=D0=BF=D1=86=D0=B8=D0=BE=D0=BD=D0=B0=D0=BB?=
 =?UTF-8?q?=D1=8C=D0=BD=D1=8B=D0=B9=20KafkaSender,=20=D0=B8=D0=BD=D0=B0?=
 =?UTF-8?q?=D1=87=D0=B5=20=D0=BD=D0=B5=20=D0=B7=D0=B0=D0=BF=D1=83=D1=81?=
 =?UTF-8?q?=D0=BA=D0=B0=D0=BB=D1=81=D1=8F=20=D0=B1=D0=B5=D0=B7=20=D0=BD?=
 =?UTF-8?q?=D0=B5=D0=BE=D0=B1=D1=8F=D0=B7=D0=B0=D1=82=D0=B5=D0=BB=D1=8C?=
 =?UTF-8?q?=D0=BD=D1=8B=D1=85=20=D0=BD=D0=B0=D1=81=D1=82=D1=80=D0=BE=D0=B5?=
 =?UTF-8?q?=D0=BA.?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../clearing/dbf/exporter/config/KafkaSenderConfig.java   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/config/KafkaSenderConfig.java b/clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/config/KafkaSenderConfig.java
index d2397c4a5..2b2319156 100644
--- a/clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/config/KafkaSenderConfig.java
+++ b/clearing-parent/dbf-exporter/src/main/java/ru/spcex/clearing/dbf/exporter/config/KafkaSenderConfig.java
@@ -1,6 +1,8 @@
 package ru.spcex.clearing.dbf.exporter.config;
 
 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.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -14,6 +16,7 @@ import ru.spcex.platform.imdg.api.ImdgProvider;
 //отдельный конфиг для sender чтобы сделать required false
 @Configuration
 public class KafkaSenderConfig {
+    Logger log = LoggerFactory.getLogger(getClass());
 
     private final ImdgProvider imdgProvider;
     private Producer<String, Object> kafkaProducer;
@@ -23,14 +26,15 @@ public class KafkaSenderConfig {
         this.imdgProvider = imdgProvider;
     }
 
-    @Autowired
+    @Autowired(required = false)
     public void setKafkaProducer(Producer<String, Object> kafkaProducer) {
         this.kafkaProducer = kafkaProducer;
     }
 
     @Bean
     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;
         }
         ImdgId imdgIdGenerator = imdgProvider.getImdgIdGenerator();