Fixed error response for Too many get partition metadata request. (ap…

…ache#1004)
adamkeyser · Dec 22, 2017 · 3e7cd2c · 3e7cd2c
1 parent 334afa0
commit 3e7cd2c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
@@ -239,7 +239,7 @@ protected void handlePartitionMetadataRequest(CommandPartitionedTopicMetadata pa
                 log.debug("[{}] Failed Partition-Metadata lookup due to too many lookup-requests {}", remoteAddress,
                         topic);
             }
-            ctx.writeAndFlush(newLookupErrorResponse(ServerError.TooManyRequests,
+            ctx.writeAndFlush(Commands.newPartitionMetadataResponse(ServerError.TooManyRequests,
                     "Failed due to too many pending lookup requests", requestId));
         }
     }