public class FieldNameTopicSelector extends Object implements KafkaTopicSelector
Uses field name to select topic name from tuple .
Constructor and Description |
---|
FieldNameTopicSelector(String fieldName,
String defaultTopicName) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.