Class FieldIndexTopicSelector

All Implemented Interfaces:
Serializable, KafkaTopicSelector

public class FieldIndexTopicSelector extends Object implements KafkaTopicSelector
Uses field with a given index to select the topic name from a tuple .
See Also:
  • Constructor Details

    • FieldIndexTopicSelector

      public FieldIndexTopicSelector(int fieldIndex, String defaultTopicName)
      Creates a new FieldIndexTopicSelector.
      fieldIndex - The index of the field containing the topic name
      defaultTopicName - The default topic name if the topic name cannot be read from the tuple
  • Method Details