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

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