Dollerok/P8-ExchangeService
1
0
Fork 0
forked from CITKParus/P8-ExchangeService
Code Issues Pull Requests Projects Releases Wiki Activity

Коннектор "Kafka" - исправлены опечатки в консольной выдаче

Browse Source
This commit is contained in:
Mikhail Chechnev 2025-11-07 18:24:22 +03:00
parent e559b534bf
commit 3721c8b4be
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
core/kafka_connector.js
View File

@ -90,7 +90,7 @@ const subscribeKafka = async ({ settings, service, processMessage, logger }) =>
}) })
}); });
} catch (e) { } 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; return consumer;
} catch (e) { } catch (e) {
await logger.error(`Ошибка запуска обработчика очереди исходящих сообщений Kafka: ${makeErrorText(e)}`); await logger.error(`Ошибка запуска обработчика очереди входящих сообщений Kafka: ${makeErrorText(e)}`);
} }
}; };