Added an endpoint to query the watermarks by partition