Changed method name in KafkaBackendClient.ts

2021-01-19 17:02:59 +02:00
parent a81bc52801
commit 1f38ef08b5
1 changed files with 2 additions and 2 deletions
@@ -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`);
  }
 }