chore(events): rename loggerServiceCreator
Signed-off-by: Jonas Beck <jonas.beck@velux.com>
This commit is contained in:
@@ -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 =>
|
||||
|
||||
+1
-1
@@ -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;
|
||||
Reference in New Issue
Block a user