a nit with isTelemetryExporterConfigured

Signed-off-by: see-quick <[email protected]>

Author: see-quick

core/src/test/scala/unit/kafka/server/KafkaApisTest.scala

@@ -11532,7 +11532,7 @@ class KafkaApisTest extends Logging {
     val request = buildRequest(new GetTelemetrySubscriptionsRequest.Builder(
       new GetTelemetrySubscriptionsRequestData(), true).build())
 
-    when(clientMetricsManager.isTelemetryReceiverConfigured).thenReturn(true)
+    when(clientMetricsManager.isTelemetryExporterConfigured).thenReturn(true)
     when(clientMetricsManager.processGetTelemetrySubscriptionRequest(any[GetTelemetrySubscriptionsRequest](),
       any[RequestContext]())).thenReturn(new GetTelemetrySubscriptionsResponse(
       new GetTelemetrySubscriptionsResponseData()))
@@ -11552,7 +11552,7 @@ class KafkaApisTest extends Logging {
     val request = buildRequest(new GetTelemetrySubscriptionsRequest.Builder(
       new GetTelemetrySubscriptionsRequestData(), true).build())
 
-    when(clientMetricsManager.isTelemetryReceiverConfigured).thenReturn(true)
+    when(clientMetricsManager.isTelemetryExporterConfigured).thenReturn(true)
     when(clientMetricsManager.processGetTelemetrySubscriptionRequest(any[GetTelemetrySubscriptionsRequest](),
       any[RequestContext]())).thenThrow(new RuntimeException("test"))
 
@@ -11570,7 +11570,7 @@ class KafkaApisTest extends Logging {
   def testPushTelemetry(): Unit = {
     val request = buildRequest(new PushTelemetryRequest.Builder(new PushTelemetryRequestData(), true).build())
 
-    when(clientMetricsManager.isTelemetryReceiverConfigured).thenReturn(true)
+    when(clientMetricsManager.isTelemetryExporterConfigured).thenReturn(true)
     when(clientMetricsManager.processPushTelemetryRequest(any[PushTelemetryRequest](), any[RequestContext]()))
       .thenReturn(new PushTelemetryResponse(new PushTelemetryResponseData()))
 
@@ -11587,7 +11587,7 @@ class KafkaApisTest extends Logging {
   def testPushTelemetryWithException(): Unit = {
     val request = buildRequest(new PushTelemetryRequest.Builder(new PushTelemetryRequestData(), true).build())
 
-    when(clientMetricsManager.isTelemetryReceiverConfigured).thenReturn(true)
+    when(clientMetricsManager.isTelemetryExporterConfigured).thenReturn(true)
     when(clientMetricsManager.processPushTelemetryRequest(any[PushTelemetryRequest](), any[RequestContext]()))
       .thenThrow(new RuntimeException("test"))
 

server/src/main/java/org/apache/kafka/server/ClientMetricsManager.java

@@ -228,7 +228,7 @@ public PushTelemetryResponse processPushTelemetryRequest(PushTelemetryRequest re
         return new PushTelemetryResponse(new PushTelemetryResponseData());
     }
 
-    public boolean isTelemetryReceiverConfigured() {
+    public boolean isTelemetryExporterConfigured() {
         return !clientTelemetryExporterPlugin.isEmpty();
     }
 

server/src/main/java/org/apache/kafka/server/DefaultApiVersionManager.java

@@ -78,7 +78,7 @@ public ApiMessageType.ListenerType listenerType() {
     public ApiVersionsResponse apiVersionResponse(int throttleTimeMs, boolean alterFeatureLevel0) {
         FinalizedFeatures finalizedFeatures = metadataCache.features();
         Optional<NodeApiVersions> controllerApiVersions = nodeApiVersionsSupplier.get();
-        boolean clientTelemetryEnabled = clientMetricsManager.map(ClientMetricsManager::isTelemetryReceiverConfigured).orElse(false);
+        boolean clientTelemetryEnabled = clientMetricsManager.map(ClientMetricsManager::isTelemetryExporterConfigured).orElse(false);
         ApiVersionsResponseData.ApiVersionCollection apiVersions = controllerApiVersions
                 .map(nodeApiVersions -> ApiVersionsResponse.controllerApiVersions(
                     nodeApiVersions,