Merge pull request #5161 from mkaufmaner/5126-change-kafka-visibility

fix(microservices): Changed visibility of Kafka variables for extension
nestjs · Jul 30, 2020 · 1ade11e · 1ade11e
2 parents b938129 + b9007dd
commit 1ade11e
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 9 deletions.
diff --git a/packages/microservices/client/client-kafka.ts b/packages/microservices/client/client-kafka.ts
@@ -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();

diff --git a/packages/microservices/server/server-kafka.ts b/packages/microservices/server/server-kafka.ts
@@ -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();