public class DefaultTopicSelector extends Object implements KafkaTopicSelector
| Constructor and Description |
|---|
DefaultTopicSelector(String topicName) |
public DefaultTopicSelector(String topicName)
public String getTopic(TridentTuple tuple)
getTopic in interface KafkaTopicSelectorCopyright © 2021 The Apache Software Foundation. All rights reserved.