### Question:
KafkaPartitionLevelStreamConfig { public int getKafkaBufferSize() { return _kafkaBufferSize; } KafkaPartitionLevelStreamConfig(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 testGetKafkaBufferSize() { KafkaPartitionLevelStreamConfig config = getStreamConfig("topic", "host1", null, ""); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_BUFFER_SIZE_DEFAULT, config.getKafkaBufferSize()); config = getStreamConfig("topic", "host1", "", ""); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_BUFFER_SIZE_DEFAULT, config.getKafkaBufferSize()); config = getStreamConfig("topic", "host1", "bad value", ""); Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_BUFFER_SIZE_DEFAULT, config.getKafkaBufferSize()); config = getStreamConfig("topic", "host1", "100", ""); Assert.assertEquals(100, config.getKafkaBufferSize()); }