Package org.apache.kafka.streams
Interface TopologyDescription.Source
-
- All Superinterfaces:
TopologyDescription.Node
- Enclosing interface:
- TopologyDescription
public static interface TopologyDescription.Source extends TopologyDescription.Node
A source node of a topology.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description PatterntopicPattern()The pattern used to match topic names that is reading from.Stringtopics()Deprecated.usetopicSet()ortopicPattern()insteadSet<String>topicSet()The topic names this source node is reading from.-
Methods inherited from interface org.apache.kafka.streams.TopologyDescription.Node
name, predecessors, successors
-
-
-
-
Method Detail
-
topics
@Deprecated String topics()
Deprecated.usetopicSet()ortopicPattern()insteadThe topic names this source node is reading from.- Returns:
- comma separated list of topic names or pattern (as String)
-
topicSet
Set<String> topicSet()
The topic names this source node is reading from.- Returns:
- a set of topic names
-
topicPattern
Pattern topicPattern()
The pattern used to match topic names that is reading from.- Returns:
- the pattern used to match topic names
-
-