package org.apache.mesos.kafka.web;

import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;

import javax.ws.rs.GET;

import javax.ws.rs.Path;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

import org.apache.mesos.config.ConfigurationService;
import org.apache.mesos.kafka.config.KafkaConfigService;
import org.apache.mesos.kafka.state.KafkaStateService;

import org.json.JSONArray;
import org.json.JSONObject;


@Path("/")
public class ClusterController {
  private final Log log = LogFactory.getLog(ClusterController.class);
  private KafkaStateService state = KafkaStateService.getStateService();
  private ConfigurationService config =  KafkaConfigService.getConfigService();

  private String zkRoot = "/" + config.get("FRAMEWORK_NAME");
  private String zkAddr = config.get("ZOOKEEPER_ADDR");

  @Path("/connection")
  @GET
  public Response getConnectionInfo() {
    try {
      JSONObject connectionInfo = new JSONObject();
      connectionInfo.put("zookeeper", zkAddr + "/" + config.get("FRAMEWORK_NAME"));
      connectionInfo.put("brokers", getBrokerList());

      return Response.ok(connectionInfo.toString(), MediaType.APPLICATION_JSON).build();

    } catch (Exception ex) {
      log.error("Failed to fetch topics with exception: " + ex);
      return Response.serverError().build();
    }
  }

  private JSONArray getBrokerList() throws Exception {
    return new JSONArray(state.getBrokerEndpoints());
  }
}

@@ -468,16 +468,18 @@
 @Path(%22/
+v1
 %22)%0Apubli

Add v1 to ClusterController path