diff --git a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/services/ReportService.java b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/services/ReportService.java
index 042f31ebc..4f3ef4bb6 100644
--- a/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/services/ReportService.java
+++ b/clearing-parent/reports-service/src/main/java/ru/spcex/clearing/reports/services/ReportService.java
@@ -25,6 +25,7 @@ import ru.spcex.clearing.platform.messaging.domain.cud.reports.ReportRequest;
 import ru.spcex.clearing.platform.messaging.domain.cud.reports.ReportRequestWithSessionId;
 import ru.spcex.clearing.platform.messaging.domain.cud.schedule.LauncherCommandRequest;
 import ru.spcex.clearing.platform.messaging.service.QueueConsumer;
+import ru.spcex.clearing.platform.messaging.service.QueueConsumerV2;
 import ru.spcex.clearing.platform.messaging.service.RequestInfoUpdate;
 import ru.spcex.clearing.platform.messaging.service.sender.KafkaSender;
 import ru.spcex.clearing.reports.builders.CSVReportBuilder;
@@ -44,7 +45,7 @@ import ru.spcex.platform.utils.enumeration.IEnumKey;
 import ru.spcex.platform.utils.validation.IValidator;
 
 @Service
-public class ReportService extends QueueConsumer implements InitializingBean {
+public class ReportService extends QueueConsumerV2 implements InitializingBean {
     private final Logger log = LoggerFactory.getLogger(getClass());
     private final ValidationHelper validationHelper;
     private final KafkaSender kafkaSender;
@@ -230,7 +231,7 @@ public class ReportService extends QueueConsumer implements InitializingBean {
     }
 
     public RequestInfoUpdate createReportForGREP(BaseRequest<LauncherCommandRequest> userRequest) {
-        log.debug("GREP task received");
+        log.debug("GREP task received; id: {}", userRequest.getId());
 
         try {
             RequestInfoUpdate requestInfoUpdate = validationHelper.validateTillFirstError(userRequest, reportRequestGREPValidator);