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

Modifier and Type	Method	Description
java.lang.String	topics()	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

java.lang.String topics()

The topic names this source node is reading from.

Returns:

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