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

Merge branch 'master' of https://github.com/nestjs/nest; branch '5603-feat-kafkaclient-kafkaserver-naming-conventions' of https://github.com/smhmayboudi/nest into smhmayboudi-5603-feat-kafkaclient-kafkaserver-naming-conventions

Browse Source
This commit is contained in:
Kamil Myśliwiec
2020-11-02 10:57:00 +01:00
parent 5128867bba 1ff912e693
commit 81550648b3
4 changed files with 6 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -56,8 +56,8 @@ export class ServerKafka extends Server implements CustomTransportStrategy {
// append a unique id to the clientId and groupId
// so they don't collide with a microservices client
this.clientId =
(clientOptions.clientId || KAFKA_DEFAULT_CLIENT) + '-server';
this.groupId = (consumerOptions.groupId || KAFKA_DEFAULT_GROUP) + '-server';
(clientOptions.clientId || KAFKA_DEFAULT_CLIENT) + (clientOptions.clientIdPostfix || '-server');
this.groupId = (consumerOptions.groupId || KAFKA_DEFAULT_GROUP) + (clientOptions.clientIdPostfix || '-server');
kafkaPackage = this.loadPackage('kafkajs', ServerKafka.name, () =>
require('kafkajs'),