amirho/nest
1
0
Fork 0
mirror of https://github.com/nestjs/nest.git synced 2026-02-21 23:11:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(microservices): when postfixId is an empty string on kafka

Browse Source
This commit is contained in:
Micael Levi (@micalevisk)
2022-05-27 23:35:08 -04:00
parent 2e3727b786
commit 0359fa4666
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/microservices/client/client-kafka.ts
View File

@@ -62,7 +62,7 @@ export class ClientKafka extends ClientProxy {
const consumerOptions =
this.getOptionsProp(this.options, 'consumer') || ({} as ConsumerConfig);
const postfixId =
this.getOptionsProp(this.options, 'postfixId') || '-client';
this.getOptionsProp(this.options, 'postfixId') ?? '-client';
this.producerOnlyMode =
this.getOptionsProp(this.options, 'producerOnlyMode') || false;

2
packages/microservices/server/server-kafka.ts
View File

@@ -53,7 +53,7 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
const consumerOptions =
this.getOptionsProp(this.options, 'consumer') || ({} as ConsumerConfig);
const postfixId =
this.getOptionsProp(this.options, 'postfixId') || '-server';
this.getOptionsProp(this.options, 'postfixId') ?? '-server';
this.brokers = clientOptions.brokers || [KAFKA_DEFAULT_BROKER];