Package org.apache.kafka.streams
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 Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description Stringtopic()The topic name this sink node is writing to.TopicNameExtractortopicNameExtractor()TheTopicNameExtractorclass that this sink node uses to dynamically extract the topic name to write to.-
Methods inherited from interface org.apache.kafka.streams.TopologyDescription.Node
name, predecessors, successors
-
-
-
-
Method Detail
-
topic
String topic()
The topic name this sink node is writing to. Could benullif the topic name can only be dynamically determined based onTopicNameExtractor- Returns:
- a topic name
-
topicNameExtractor
TopicNameExtractor topicNameExtractor()
TheTopicNameExtractorclass that this sink node uses to dynamically extract the topic name to write to. Could benullif the topic name is not dynamically determined.- Returns:
- the
TopicNameExtractorclass used get the topic name
-
-