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 and Description
Set<String>	stores() The names of all connected stores.

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

name, predecessors, successors

Method Detail

stores

Set<String> stores()

The names of all connected stores.

Returns:

set of store names