public class DefaultTopicSelector extends Object implements KafkaTopicSelector
Constructor and Description |
---|
DefaultTopicSelector(String topicName) |
public DefaultTopicSelector(String topicName)
public String getTopic(Tuple tuple)
getTopic
in interface KafkaTopicSelector
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.