diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/config/KafkaConfig.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/config/KafkaConfig.java index cd3b73821..3a7f95b94 100644 --- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/config/KafkaConfig.java +++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/config/KafkaConfig.java @@ -20,9 +20,9 @@ public class KafkaConfig { return KafkaConsumerFactory.consumer(settings.getKafkaConsumer()); } -// @Autowired -// @Bean -// public Producer createProducer(ReportsServiceSettings settings) { -// return KafkaProducerFactory.producer(settings.getKafkaProducer()); -// } + @Autowired + @Bean + public Producer createProducer(ReportsServiceSettings settings) { + return KafkaProducerFactory.producer(settings.getKafkaProducer()); + } }