fix test 1

linkedin · Nov 6, 2023 · e97abf2 · e97abf2
1 parent 68c0625
commit e97abf2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/clients/src/main/resources/common/message/LiListFederatedTopicZnodesRequest.json b/clients/src/main/resources/common/message/LiListFederatedTopicZnodesRequest.json
@@ -16,7 +16,7 @@
 {
   "apiKey": 1005,
   "type": "request",
-  "listeners": ["zkBroker"],
+  "listeners": ["zkBroker", "broker"],
   "name": "LiListFederatedTopicZnodesRequest",
   "validVersions": "0-1",
   "flexibleVersions": "0+",

diff --git a/core/src/main/scala/kafka/server/KafkaApis.scala b/core/src/main/scala/kafka/server/KafkaApis.scala
@@ -3823,9 +3823,10 @@ class KafkaApis(val requestChannel: RequestChannel,
 
     // only do authorization on cluster level, users are not expected to track this directly via kafka
     if (!authHelper.authorize(request.context, DESCRIBE, CLUSTER, CLUSTER_NAME)) {
-      requestHelper.sendResponseExemptThrottle(request,
-        LiListFederatedTopicZnodesResponse.prepareResponse(
-          Errors.CLUSTER_AUTHORIZATION_FAILED, 0, listfederatedTopicZnodesRequest.version())
+      requestHelper.sendResponseMaybeThrottle(request, requestThrottleMs =>
+          LiListFederatedTopicZnodesResponse.prepareResponse(
+            Errors.CLUSTER_AUTHORIZATION_FAILED, requestThrottleMs, listfederatedTopicZnodesRequest.version()
+        )
       )
       return
     }