SUPPORT-9368: ФИКС

This commit is contained in:
adel.ka 2025-10-16 13:48:42 +03:00
parent a63b20b119
commit f27bbe58b0

View file

@ -14,13 +14,13 @@ import ru.micord.ervu.model.ValidateExportResponse;
*/ */
@Service @Service
public class ValidationFileService { public class ValidationFileService {
private final ReplyingKafkaService<Object, Bytes> replyingKafkaService; private final ReplyingKafkaService<String, Bytes> replyingKafkaService;
private final ObjectMapper objectMapper; private final ObjectMapper objectMapper;
private final String validateExportRequestTopic; private final String validateExportRequestTopic;
private final String validateExportReplyTopic; private final String validateExportReplyTopic;
public ValidationFileService( public ValidationFileService(
ReplyingKafkaService<Object, Bytes> replyingKafkaService, ReplyingKafkaService<String, Bytes> replyingKafkaService,
ObjectMapper objectMapper, ObjectMapper objectMapper,
@Value("${ervu.kafka.validate.export.request}") String validateExportRequestTopic, @Value("${ervu.kafka.validate.export.request}") String validateExportRequestTopic,
@Value("${ervu.kafka.validate.export.response}") String validateExportReplyTopic) { @Value("${ervu.kafka.validate.export.response}") String validateExportReplyTopic) {