public int getKafkaFetcherSizeBytes() {
    return _kafkaFetcherSizeBytes;
  }
@Test
  public void testGetFetcherSize() {
    // test default
    KafkaPartitionLevelStreamConfig config = getStreamConfig("topic", "host1", "", "", "", null, null);
    Assert.assertEquals(KafkaStreamConfigProperties.LowLevelConsumer.KAFKA_BUFFER_SIZE_DEFAULT,
        config.getKafkaFetcherSizeBytes());

    config = getStreamConfig("topic", "host1", "100", "", "", null, null);
    Assert.assertEquals(100, config.getKafkaFetcherSizeBytes());

    config = getStreamConfig("topic", "host1", "100", "", "bad value", null, null);
    Assert.assertEquals(100, config.getKafkaFetcherSizeBytes());

    // correct config
    config = getStreamConfig("topic", "host1", "100", "", "200", null, null);
    Assert.assertEquals(200, config.getKafkaFetcherSizeBytes());
  }