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): Changed visibility of Kafka variables for extension

Browse Source
This commit is contained in:
Michael Kaufman
2020-07-29 11:51:29 -04:00
parent 50c709c4d5
commit b9007dd93f
2 changed files with 10 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -43,13 +43,13 @@ export class ClientKafka extends ClientProxy {
protected client: Kafka = null;
protected consumer: Consumer = null;
protected producer: Producer = null;
protected readonly logger = new Logger(ClientKafka.name);
protected readonly responsePatterns: string[] = [];
protected logger = new Logger(ClientKafka.name);
protected responsePatterns: string[] = [];
protected consumerAssignments: { [key: string]: number[] } = {};
private readonly brokers: string[];
private readonly clientId: string;
private readonly groupId: string;
protected brokers: string[];
protected clientId: string;
protected groupId: string;
constructor(protected readonly options: KafkaOptions['options']) {
super();

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

@@ -33,13 +33,14 @@ let kafkaPackage: any = {};
export class ServerKafka extends Server implements CustomTransportStrategy {
public readonly transportId = Transport.KAFKA;
protected readonly logger = new Logger(ServerKafka.name);
protected logger = new Logger(ServerKafka.name);
protected client: Kafka = null;
protected consumer: Consumer = null;
protected producer: Producer = null;
private readonly brokers: string[];
private readonly clientId: string;
private readonly groupId: string;
protected brokers: string[];
protected clientId: string;
protected groupId: string;
constructor(private readonly options: KafkaOptions['options']) {
super();