Interface | Description |
---|---|
KafkaTopicSelector |
Class | Description |
---|---|
DefaultTopicSelector | |
FieldIndexTopicSelector |
Uses field with a given index to select the topic name from a tuple .
|
FieldNameTopicSelector |
Uses field name to select topic name from tuple .
|
Copyright © 2020 The Apache Software Foundation. All rights reserved.