From a63b20b1195deeb05819d78d0a78b5ac46f64462 Mon Sep 17 00:00:00 2001 From: "adel.ka" Date: Thu, 16 Oct 2025 13:16:53 +0300 Subject: [PATCH] =?UTF-8?q?SUPPORT-9368:=20=D0=BF=D0=BE=D0=BC=D0=B5=D0=BD?= =?UTF-8?q?=D1=8F=D0=BB=20=D0=BF=D0=B5=D1=80=D0=B5=D0=BC=D0=B5=D0=BD=D0=BD?= =?UTF-8?q?=D1=8B=D0=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/ru/micord/ervu/kafka/ReplyingKafkaConfig.java | 2 +- .../java/ru/micord/ervu/service/ValidationFileService.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/backend/src/main/java/ru/micord/ervu/kafka/ReplyingKafkaConfig.java b/backend/src/main/java/ru/micord/ervu/kafka/ReplyingKafkaConfig.java index 0c7b28a9..c408bd53 100644 --- a/backend/src/main/java/ru/micord/ervu/kafka/ReplyingKafkaConfig.java +++ b/backend/src/main/java/ru/micord/ervu/kafka/ReplyingKafkaConfig.java @@ -56,7 +56,7 @@ public class ReplyingKafkaConfig { private String saslMechanism; @Value("${av.kafka.download.response}") private String avReplyTopic; - @Value("${ervu.kafka.validate.export.reply.topic}") + @Value("${ervu.kafka.validate.export.response}") private String validateReplyTopic; @Bean diff --git a/backend/src/main/java/ru/micord/ervu/service/ValidationFileService.java b/backend/src/main/java/ru/micord/ervu/service/ValidationFileService.java index c116bf26..f3286c52 100644 --- a/backend/src/main/java/ru/micord/ervu/service/ValidationFileService.java +++ b/backend/src/main/java/ru/micord/ervu/service/ValidationFileService.java @@ -22,8 +22,8 @@ public class ValidationFileService { public ValidationFileService( ReplyingKafkaService replyingKafkaService, ObjectMapper objectMapper, - @Value("${ervu.kafka.validate.export.request.topic}") String validateExportRequestTopic, - @Value("${ervu.kafka.validate.export.reply.topic}") String validateExportReplyTopic) { + @Value("${ervu.kafka.validate.export.request}") String validateExportRequestTopic, + @Value("${ervu.kafka.validate.export.response}") String validateExportReplyTopic) { this.replyingKafkaService = replyingKafkaService; this.objectMapper = objectMapper; this.validateExportRequestTopic = validateExportRequestTopic;