Package org.apache.kafka.streams

Interface TopologyDescription.Processor

All Superinterfaces:

TopologyDescription.Node

Enclosing interface:

TopologyDescription

public static interface TopologyDescription.Processor
extends TopologyDescription.Node

A processor node of a topology.

Method Summary

Modifier and Type	Method	Description
java.util.Set<java.lang.String>	stores()	The names of all connected stores.

Methods inherited from interface org.apache.kafka.streams.TopologyDescription.Node

name, predecessors, successors

Method Detail

stores

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

The names of all connected stores.

Returns:

set of store names