diff --git a/plugins/events-backend-module-kafka/src/publisher/KafkaConsumingEventPublisher.ts b/plugins/events-backend-module-kafka/src/publisher/KafkaConsumingEventPublisher.ts index cc794481cf..223e4e99ac 100644 --- a/plugins/events-backend-module-kafka/src/publisher/KafkaConsumingEventPublisher.ts +++ b/plugins/events-backend-module-kafka/src/publisher/KafkaConsumingEventPublisher.ts @@ -69,7 +69,6 @@ export class KafkaConsumingEventPublisher { async start(): Promise { try { await this.kafkaConsumer.connect(); - this.logger.info('Kafka consumer connected'); await this.kafkaConsumer.subscribe(this.consumerSubscribeTopics); @@ -89,7 +88,6 @@ export class KafkaConsumingEventPublisher { async shutdown(): Promise { await this.kafkaConsumer.disconnect(); - this.logger.info('Kafka consumer disconnected'); } private convertHeadersToMetadata = (