This commit is contained in:
etreschenkov 2022-10-04 11:43:27 +03:00
parent 9f0f036356
commit 7caa776828

View file

@ -137,7 +137,7 @@ public class StatementService extends QueueConsumer implements InitializingBean
} }
} }
ExportToFileRequest exportRequest = new ExportToFileRequest(); ExportToFileRequest exportRequest = new ExportToFileRequest();
exportRequest.setSdfGroupId(statementRequest.getSdf01GroupId()); exportRequest.setSdfGroupId(generationIdForGroup);
exportRequest.setNameOfTable("DF-02"); exportRequest.setNameOfTable("DF-02");
kafkaReqProducer.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest); kafkaReqProducer.sendRequestToQueue(Consts.EXPORT_PROCESS, exportRequest);
} }