org.apache.kafka.streams

Interface TopologyDescription.GlobalStore

Enclosing interface:

TopologyDescription

public static interface TopologyDescription.GlobalStore

Represents a Topology.addGlobalStore(org.apache.kafka.streams.processor.StateStoreSupplier, String, org.apache.kafka.common.serialization.Deserializer, org.apache.kafka.common.serialization.Deserializer, String, String, ProcessorSupplier) global 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 a TopologyDescription.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 any TopologyDescription.Subtopology.

Method Summary

Modifier and Type	Method and Description
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