### Question:
KafkaLowLevelStreamConfig { public String getBootstrapHosts() { return _bootstrapHosts; } KafkaLowLevelStreamConfig(StreamConfig streamConfig); String getKafkaTopicName(); String getBootstrapHosts(); int getKafkaBufferSize(); int getKafkaSocketTimeout(); int getKafkaFetcherSizeBytes(); int getKafkaFetcherMinBytes(); @Override String toString(); @Override boolean equals(Object o); @Override int hashCode();  }### Answer:
@Test public void testGetBootstrapHosts() { KafkaLowLevelStreamConfig config = getStreamConfig("topic", "host1", "", ""); Assert.assertEquals("host1", config.getBootstrapHosts()); }