public String getKafkaIsolationLevel() {
    return _kafkaIsolationLevel;
  }
@Test
  public void testGetKafkaIsolationLevel() {
    KafkaPartitionLevelStreamConfig config = getStreamConfig("topic", "", "", "", "read_committed");
    Assert.assertEquals("read_committed", config.getKafkaIsolationLevel());
  }