### Question:
KafkaLowLevelStreamConfig { public int getKafkaSocketTimeout() { return _kafkaSocketTimeout; } 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 testGetKafkaSocketTimeout() { KafkaLowLevelStreamConfig config = getStreamConfig("topic", "host1", "", null); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_SOCKET_TIMEOUT_DEFAULT, config.getKafkaSocketTimeout()); config = getStreamConfig("topic", "host1", "", ""); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_SOCKET_TIMEOUT_DEFAULT, config.getKafkaSocketTimeout()); config = getStreamConfig("topic", "host1", "", "bad value"); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_SOCKET_TIMEOUT_DEFAULT, config.getKafkaSocketTimeout()); config = getStreamConfig("topic", "host1", "", "100"); Assert.assertEquals(100, config.getKafkaSocketTimeout()); }