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

Modifier and Type	Method and Description
java.util.regex.Pattern	topicPattern() The pattern used to match topic names that is reading from.
java.lang.String	topics() Deprecated. use topicSet() or topicPattern() instead
java.util.Set<java.lang.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
java.lang.String topics()

Deprecated. use topicSet() or topicPattern() instead

The topic names this source node is reading from.

Returns:

comma separated list of topic names or pattern (as String)

topicSet

java.util.Set<java.lang.String> topicSet()

The topic names this source node is reading from.

Returns:

a set of topic names

topicPattern

java.util.regex.Pattern topicPattern()

The pattern used to match topic names that is reading from.

Returns:

the pattern used to match topic names