From 946f88f0ca6402a6ea4c76351616270727bb2975 Mon Sep 17 00:00:00 2001 From: Jonas Beck <112394761+Jonas-Beck@users.noreply.github.com> Date: Wed, 4 Jun 2025 08:51:55 +0200 Subject: [PATCH] Update plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Co-authored-by: Fredrik Adelöw Signed-off-by: Jonas Beck <112394761+Jonas-Beck@users.noreply.github.com> --- .../src/publisher/KafkaConsumerClient.ts | 4 ++-- .../src/publisher/LoggerServiceAdapter.ts | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/plugins/events-backend-module-kafka/src/publisher/KafkaConsumerClient.ts b/plugins/events-backend-module-kafka/src/publisher/KafkaConsumerClient.ts index 5b6366b84d..762a95dd41 100644 --- a/plugins/events-backend-module-kafka/src/publisher/KafkaConsumerClient.ts +++ b/plugins/events-backend-module-kafka/src/publisher/KafkaConsumerClient.ts @@ -19,7 +19,7 @@ import { EventsService } from '@backstage/plugin-events-node'; import { Kafka } from 'kafkajs'; import { KafkaEventSourceConfig, readConfig } from './config'; import { KafkaConsumingEventPublisher } from './KafkaConsumingEventPublisher'; -import { LoggerServiceAdapter } from './LoggerServiceAdapter'; +import { loggerServiceAdapter } from './LoggerServiceAdapter'; /** * KafkaConsumerClient @@ -51,7 +51,7 @@ export class KafkaConsumerClient { ) { this.kafka = new Kafka({ ...config.kafkaConfig, - logCreator: LoggerServiceAdapter(logger), + logCreator: loggerServiceAdapter(logger), }); this.consumers = config.kafkaConsumerConfigs.map(consumerConfig => diff --git a/plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts b/plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts index 3750d0c8a1..b9e9379104 100644 --- a/plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts +++ b/plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts @@ -16,7 +16,7 @@ import { LoggerService } from '@backstage/backend-plugin-api'; import { LogEntry, logLevel } from 'kafkajs'; -export const LoggerServiceAdapter = +export const loggerServiceAdapter = (loggerService: LoggerService) => (_level: logLevel) => { return (entry: LogEntry) => { const { namespace, level, log } = entry;