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 84dd75c82..2d8134533 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
@@ -53,10 +53,10 @@ public class TradeImporterService {
     }
 
     public void process(boolean byCommand) {
-        log.debug("start process import STrades from DB");
+        log.debug("Start process import STrades from DB");
         Collection<STrades> tradesFromDB = jdbcTemplate.query("SELECT * FROM Trades", (resultSet, i) -> readSTrades(resultSet));
 
-        log.debug(String.format("load from DB STrades: %d", tradesFromDB.size()));
+        log.debug("load from DB STrades: {}", tradesFromDB.size());
         for (STrades tradesDb : tradesFromDB) {
             if (isValidTrades(tradesDb)) {
                 STrades sTrades = getSTradesFromImdg(tradesDb, sTradesImdg);
@@ -70,8 +70,10 @@ 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");
-        }else log.debug("successfully import STrades from DB by scheduled");
+            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");
+        }
     }
 
     public STrades getSTradesFromImdg(STrades tradesDb, Imdg<STrades> sTradesImdg) {