Interface TopologyDescription.Sink

All Superinterfaces:
TopologyDescription.Node
Enclosing interface:
TopologyDescription

public static interface TopologyDescription.Sink extends TopologyDescription.Node
A sink node of a topology.
  • Method Details

    • topic

      String topic()
      The topic name this sink node is writing to. Could be null if the topic name can only be dynamically determined based on TopicNameExtractor
      Returns:
      a topic name
    • topicNameExtractor

      TopicNameExtractor topicNameExtractor()
      The TopicNameExtractor class that this sink node uses to dynamically extract the topic name to write to. Could be null if the topic name is not dynamically determined.
      Returns:
      the TopicNameExtractor class used get the topic name