Interface TopologyDescription.Sink

    • Method Detail

      • 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