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;