Skip to content

Commit

Permalink
style: pretty logs
Browse files Browse the repository at this point in the history
  • Loading branch information
Val-istar-Guo committed Jan 28, 2024
1 parent aee4c5c commit 1db1fb5
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion src/kafka-consumer.service.ts
Original file line number Diff line number Diff line change
Expand Up @@ -59,7 +59,7 @@ export class KafkaConsumerService implements OnModuleInit, OnModuleDestroy {
const options = this.reflector.get<KafkaConsumeMetadata>(KAFKA_CONSUME, instance[method])

await consumer.subscribe({ topics: options.topics })
this.logger.log(`Subscribe ${options.topics.join(',')}`)
this.logger.log(`Subscribe topics ${options.topics.join(',')}`)

const messageIndex = this.reflector.get(MESSAGE_ARGUMENT_INDEX, instance[method])
const contextIndex = this.reflector.get(CONTEXT_ARGUMENT_INDEX, instance[method])
Expand Down

0 comments on commit 1db1fb5

Please sign in to comment.