Package org.apache.kafka.streams
Interface TopologyDescription.GlobalStore
-
- Enclosing interface:
- TopologyDescription
public static interface TopologyDescription.GlobalStore
Represents aglobal store
. Adding a global store results in adding a source node and one stateful processor node. Note, that all added global stores form a single unit (similar to aTopologyDescription.Subtopology
) even if different global stores are not connected to each other. Furthermore, global stores are available to all processors without connecting them explicitly, and thus global stores will never be part of anyTopologyDescription.Subtopology
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description int
id()
TopologyDescription.Processor
processor()
The processor node maintaining the global store.TopologyDescription.Source
source()
The source node reading from a "global" topic.
-
-
-
Method Detail
-
source
TopologyDescription.Source source()
The source node reading from a "global" topic.- Returns:
- the "global" source node
-
processor
TopologyDescription.Processor processor()
The processor node maintaining the global store.- Returns:
- the "global" processor node
-
id
int id()
-
-