### Question:
Burrow { public List<String> consumerGroups(String cluster) throws IOException { return (List<String>) this.request(cluster, "consumer").get("consumers"); } Burrow(Map<String, Object> conf);  Burrow(Map<String, Object> conf, OkHttpClient client);   Burrow(Map<String, Object> conf, OkHttpClient client, boolean doHealthCheck); List<String> consumerGroups(String cluster); Map<String, Object> getConsumerGroupStatus(String cluster, String consumerGroup); List<ClusterClient> getClusters();  }### Answer:
@Test public void testConsumers() throws Exception { OkHttpClient client = Mockito.mock(OkHttpClient.class); Map<String, Object> response = new HashMap<>(); List<String> expected = Lists.newArrayList("one", "two"); response.put("consumers", expected); when(client.newCall(any())).then(respondWithJson(response)); Burrow burrow = new Burrow(CONF, client); assertEquals(expected, burrow.consumerGroups("cluster")); verify(client).newCall(expectPath("/v3/kafka/cluster/consumer")); }