Class InternalTopologyBuilder.Sink<K,V>
- java.lang.Object
-
- org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.AbstractNode
-
- org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.Sink<K,V>
-
- All Implemented Interfaces:
TopologyDescription.Node
,TopologyDescription.Sink
- Enclosing class:
- InternalTopologyBuilder
public static final class InternalTopologyBuilder.Sink<K,V> extends InternalTopologyBuilder.AbstractNode implements TopologyDescription.Sink
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addSuccessor(TopologyDescription.Node successor)
boolean
equals(Object o)
int
hashCode()
String
topic()
The topic name this sink node is writing to.TopicNameExtractor<K,V>
topicNameExtractor()
TheTopicNameExtractor
class that this sink node uses to dynamically extract the topic name to write to.String
toString()
-
Methods inherited from class org.apache.kafka.streams.processor.internals.InternalTopologyBuilder.AbstractNode
addPredecessor, name, predecessors, successors
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.kafka.streams.TopologyDescription.Node
name, predecessors, successors
-
-
-
-
Method Detail
-
topic
public String topic()
Description copied from interface:TopologyDescription.Sink
The topic name this sink node is writing to. Could benull
if the topic name can only be dynamically determined based onTopicNameExtractor
- Specified by:
topic
in interfaceTopologyDescription.Sink
- Returns:
- a topic name
-
topicNameExtractor
public TopicNameExtractor<K,V> topicNameExtractor()
Description copied from interface:TopologyDescription.Sink
TheTopicNameExtractor
class that this sink node uses to dynamically extract the topic name to write to. Could benull
if the topic name is not dynamically determined.- Specified by:
topicNameExtractor
in interfaceTopologyDescription.Sink
- Returns:
- the
TopicNameExtractor
class used get the topic name
-
addSuccessor
public void addSuccessor(TopologyDescription.Node successor)
- Overrides:
addSuccessor
in classInternalTopologyBuilder.AbstractNode
-
-