public String getBootstrapHosts() {
    return _bootstrapHosts;
  }
@Test
  public void testGetBootstrapHosts() {
    KafkaPartitionLevelStreamConfig config = getStreamConfig("topic", "host1", "", "");
    Assert.assertEquals("host1", config.getBootstrapHosts());
  }