From 1f38ef08b5a0ad52bd265d92a78565127c0a7700 Mon Sep 17 00:00:00 2001
From: Nir Gazit <nir.gzt@gmail.com>
Date: Tue, 19 Jan 2021 17:02:59 +0200
Subject: [PATCH] Changed method name in KafkaBackendClient.ts

---
 plugins/kafka/src/api/KafkaBackendClient.ts | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/plugins/kafka/src/api/KafkaBackendClient.ts b/plugins/kafka/src/api/KafkaBackendClient.ts
index 2112dd0f17..4b41323098 100644
--- a/plugins/kafka/src/api/KafkaBackendClient.ts
+++ b/plugins/kafka/src/api/KafkaBackendClient.ts
@@ -24,7 +24,7 @@ export class KafkaBackendClient implements KafkaApi {
     this.discoveryApi = options.discoveryApi;
   }
 
-  private async getRequired(path: string): Promise<any> {
+  private async internalGet(path: string): Promise<any> {
     const url = `${await this.discoveryApi.getBaseUrl('kafka')}${path}`;
     const response = await fetch(url, {
       method: 'GET',
@@ -45,6 +45,6 @@ export class KafkaBackendClient implements KafkaApi {
   async getConsumerGroupOffsets(
     consumerGroup: string,
   ): Promise<ConsumerGroupOffsetsResponse> {
-    return await this.getRequired(`/consumer/${consumerGroup}/offsets`);
+    return await this.internalGet(`/consumer/${consumerGroup}/offsets`);
   }
 }