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 { + private async internalGet(path: string): Promise { 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 { - return await this.getRequired(`/consumer/${consumerGroup}/offsets`); + return await this.internalGet(`/consumer/${consumerGroup}/offsets`); } }