chore(kafka): update loggerServiceAdapter

Signed-off-by: Jonas Beck <dev@jonasbeck.dk>
This commit is contained in:
Jonas Beck
2025-07-29 16:48:23 +02:00
parent aa83cc0d50
commit 637ed06de6
@@ -16,23 +16,21 @@
import { LoggerService } from '@backstage/backend-plugin-api';
import { LogEntry, logLevel } from 'kafkajs';
export const loggerServiceAdapter =
(loggerService: LoggerService) => (_level: logLevel) => {
export const loggerServiceAdapter = (loggerService: LoggerService) => {
const logMethods: Record<logLevel, (message: string, meta?: object) => void> =
{
[logLevel.ERROR]: loggerService.error,
[logLevel.WARN]: loggerService.warn,
[logLevel.INFO]: loggerService.info,
[logLevel.DEBUG]: loggerService.debug,
[logLevel.NOTHING]: () => {},
};
return (_level: logLevel) => {
return (entry: LogEntry) => {
const { namespace, level, log } = entry;
const { message, ...extra } = log;
const logMethods: Record<
logLevel,
(message: string, meta?: object) => void
> = {
[logLevel.ERROR]: loggerService.error,
[logLevel.WARN]: loggerService.warn,
[logLevel.INFO]: loggerService.info,
[logLevel.DEBUG]: loggerService.debug,
[logLevel.NOTHING]: () => {},
};
// Use loggerService method that matches the level
logMethods[level].call(
loggerService,
@@ -43,3 +41,4 @@ export const loggerServiceAdapter =
);
};
};
};