### Question:
SimpleConsumerManager implements Closeable { static String extractBroker(URI uri) { String uriStr = uri.toString(); int start = uriStr.indexOf("/") + 2; int end = uriStr.indexOf("/", start); if (end < 0) { return uriStr.substring(start); } else { return uriStr.substring(start, end); } } SimpleConsumerManager(URI uri, String topic, int partitionId);  SimpleConsumerManager(URI uri, String topic, int partitionId, int fragmentSize); @Override void close(); long getEarliestOffset(); long getLatestOffset(); ConsumerRecords<byte[], byte[]> poll(long offset, long timeout);  }### Answer:
@Test public void testExtractBroker() { assertEquals("host1:9092,host2:9092,host3:9092", SimpleConsumerManager.extractBroker(URI.create("kafka: assertEquals("host1:9092,host2:9092,host3:9092", SimpleConsumerManager.extractBroker(URI.create("kafka: }