From 637ed06de63d2fdf0e2d429cb5fcf1e85596fe28 Mon Sep 17 00:00:00 2001 From: Jonas Beck Date: Tue, 29 Jul 2025 16:48:23 +0200 Subject: [PATCH] chore(kafka): update loggerServiceAdapter Signed-off-by: Jonas Beck --- .../src/publisher/LoggerServiceAdapter.ts | 25 +++++++++---------- 1 file changed, 12 insertions(+), 13 deletions(-) diff --git a/plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts b/plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts index b9e9379104..5d635fb919 100644 --- a/plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts +++ b/plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts @@ -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 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 = ); }; }; +};