public String getKafkaTopicName() {
    return _kafkaTopicName;
  }
@Test
  public void testGetKafkaTopicName() {
    KafkaPartitionLevelStreamConfig config = getStreamConfig("topic", "", "", "");
    Assert.assertEquals("topic", config.getKafkaTopicName());
  }