Update plugins/events-backend-module-kafka/src/publisher/LoggerServiceAdapter.ts
Co-authored-by: Fredrik Adelöw <freben@gmail.com> Signed-off-by: Jonas Beck <112394761+Jonas-Beck@users.noreply.github.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 { 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 =>
|
||||
|
||||
@@ -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;
|
||||
|
||||
Reference in New Issue
Block a user