diff --git a/core/kafka_connector.js b/core/kafka_connector.js
index e2b89c3..1ba72a0 100644
--- a/core/kafka_connector.js
+++ b/core/kafka_connector.js
@@ -90,7 +90,7 @@ const subscribeKafka = async ({ settings, service, processMessage, logger }) =>
                         })
                     });
                 } catch (e) {
-                    await logger.error(`Ошибка обработки исходящего сообщения Kafka: ${makeErrorText(e)}`);
+                    await logger.error(`Ошибка обработки входящего сообщения Kafka: ${makeErrorText(e)}`);
                 }
             }
         });
@@ -107,7 +107,7 @@ const subscribeKafka = async ({ settings, service, processMessage, logger }) =>
         //Возвращаем соединение
         return consumer;
     } catch (e) {
-        await logger.error(`Ошибка запуска обработчика очереди исходящих сообщений Kafka: ${makeErrorText(e)}`);
+        await logger.error(`Ошибка запуска обработчика очереди входящих сообщений Kafka: ${makeErrorText(e)}`);
     }
 };