@Test public void testGetKafkaTopicName() { KafkaPartitionLevelStreamConfig config = getStreamConfig("topic", "", "", ""); Assert.assertEquals("topic", config.getKafkaTopicName()); }
public String getKafkaTopicName() { return _kafkaTopicName; }
KafkaPartitionLevelStreamConfig { public String getKafkaTopicName() { return _kafkaTopicName; } }
KafkaPartitionLevelStreamConfig { public String getKafkaTopicName() { return _kafkaTopicName; } KafkaPartitionLevelStreamConfig(StreamConfig streamConfig); }
KafkaPartitionLevelStreamConfig { public String getKafkaTopicName() { return _kafkaTopicName; } 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(); }
KafkaPartitionLevelStreamConfig { public String getKafkaTopicName() { return _kafkaTopicName; } 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();  }