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 SummaryAll 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.Nodename, predecessors, successors
 
- 
 
- 
- 
- 
Method Detail- 
topicString 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
 
 - 
topicNameExtractorTopicNameExtractor 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
 
 
- 
 
-