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 Pattern
topicPattern()
The pattern used to match topic names that is reading from.String
topics()
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
-
-