diff --git a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
index 2d8134533..551119d24 100644
--- a/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
+++ b/clearing-parent/trade-importer/src/main/java/ru/spcex/clearing/trade/importer/services/TradeImporterService.java
@@ -68,12 +68,12 @@ public class TradeImporterService {
         }
 
         if (byCommand) {
-            STradesImportedRequest sTradesImportedRequest = new STradesImportedRequest();
-            producer.send(new ProducerRecord<>(S_TRADES_IMPORTED, sTradesImportedRequest));
             log.debug("Successfully import STrades from DB by command. Send to kafka command, topic={}", S_TRADES_IMPORTED);
         } else {
-            log.debug("Successfully import STrades from DB by scheduled");
+            log.debug("Successfully import STrades from DB by scheduled. Send to kafka command, topic={}", S_TRADES_IMPORTED);
         }
+        STradesImportedRequest sTradesImportedRequest = new STradesImportedRequest();
+        producer.send(new ProducerRecord<>(S_TRADES_IMPORTED, sTradesImportedRequest));
     }
 
     public STrades getSTradesFromImdg(STrades tradesDb, Imdg<STrades> sTradesImdg) {