diff --git a/plugins/kafka/src/api/KafkaBackendClient.ts b/plugins/kafka/src/api/KafkaBackendClient.ts index 45b1616fe0..8166da4601 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', @@ -46,7 +46,7 @@ export class KafkaBackendClient implements KafkaApi { clusterId: string, consumerGroup: string, ): Promise { - return await this.getRequired( + return await this.internalGet( `/consumers/${clusterId}/${consumerGroup}/offsets`, ); }