diff --git a/plugins/events-backend-module-kafka/src/publisher/KafkaConsumerClient.ts b/plugins/events-backend-module-kafka/src/publisher/KafkaConsumerClient.ts index 16c2734aef..5b6366b84d 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 { LoggerServiceCreator } from './LoggerServiceCreator'; +import { LoggerServiceAdapter } from './LoggerServiceAdapter'; /** * KafkaConsumerClient @@ -51,7 +51,7 @@ export class KafkaConsumerClient { ) { this.kafka = new Kafka({ ...config.kafkaConfig, - logCreator: LoggerServiceCreator(logger), + logCreator: LoggerServiceAdapter(logger), }); this.consumers = config.kafkaConsumerConfigs.map(consumerConfig => diff --git a/plugins/events-backend-module-kafka/src/publisher/LoggerServiceCreator.ts b/plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts similarity index 97% rename from plugins/events-backend-module-kafka/src/publisher/LoggerServiceCreator.ts rename to plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts index 0dd5f9cd84..3750d0c8a1 100644 --- a/plugins/events-backend-module-kafka/src/publisher/LoggerServiceCreator.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 LoggerServiceCreator = +export const LoggerServiceAdapter = (loggerService: LoggerService) => (_level: logLevel) => { return (entry: LogEntry) => { const { namespace, level, log } = entry;