### Question:
Burrow { public Map<String, Object> getConsumerGroupStatus(String cluster, String consumerGroup) throws IOException { return (Map<String, Object>) this.request(cluster, "consumer", consumerGroup, "lag").get("status"); } 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 testStatus() throws Exception { Map<String, Object> response = new HashMap<>(); response.put("error", false); response.put("message", "consumer status returned"); Map<String, Object> expected = new HashMap<>(); expected.put("cluster", "cluster"); expected.put("group", "some.group"); List<Map<String, Object>> partitions = new ArrayList<>(); expected.put("partitions", partitions); response.put("status", expected); OkHttpClient client = Mockito.mock(OkHttpClient.class); when(client.newCall(any())).then(respondWithJson(response)); Burrow burrow = new Burrow(CONF, client); assertEquals(expected, burrow.getConsumerGroupStatus("cluster", "some.group")); verify(client).newCall(expectPath("/v3/kafka/cluster/consumer/some.group/lag")); }