Interface TopologyDescription.Sink

All Superinterfaces:
Enclosing interface:

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
      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.
      the TopicNameExtractor class used get the topic name