Fixed error response for Too many get partition metadata request.
@@ -239,7 +239,7 @@ public class ServerCnx extends PulsarHandler {
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));
}
}
