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 KafkaTopicSelector
Copyright © 2022 The Apache Software Foundation. All rights reserved.