apoorvmittal10 commented on code in PR #14767:
URL: https://github.com/apache/kafka/pull/14767#discussion_r1410158203
##########
core/src/main/scala/kafka/server/KafkaApis.scala:
##########
@@ -3697,16 +3698,60 @@ class KafkaApis(val requestChannel: RequestChannel,
CompletableFuture.completedFuture[Unit](())
}
- // Just a place holder for now.
def handleGetTelemetrySubscriptionsRequest(request: RequestChannel.Request):
Unit = {
- requestHelper.sendMaybeThrottle(request,
request.body[GetTelemetrySubscriptionsRequest].getErrorResponse(Errors.UNSUPPORTED_VERSION.exception))
- CompletableFuture.completedFuture[Unit](())
+ val subscriptionRequest = request.body[GetTelemetrySubscriptionsRequest]
+
+ if (ClientMetricsReceiverPlugin.instance.isEmpty) {
+ info("Received get telemetry client request, no metrics receiver plugin
configured or running with ZK")
+ requestHelper.sendResponseMaybeThrottle(request, requestThrottleMs =>
+ subscriptionRequest.getErrorResponse(requestThrottleMs,
Errors.UNSUPPORTED_VERSION.exception))
Review Comment:
Thanks for the quick reply @junrao, I am looking into this. I thought the
suggestion was to have a flag similar to `zkMigrationEnabled`, but it looks
like to not emit APIKeys of telemetry if plugin is missing.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
