GlobalKTable — Global Changelog Stream

GlobalKTable is the abstraction of changelog streams that are global and have a local state store registered under the optional queryableStoreName.

Table 1. GlobalKTable Contract
Method Description

queryableStoreName

 
String queryableStoreName()

Name of the local state store that can be used in interactive queries. If null, the local state store of the GlobalKTable cannot be queried (and so the GlobalKTable is not queryable).
Note
 GlobalKTable is an Evolving contract which means that compatibility may be broken at a minor release.
Note
 GlobalKTableImpl is the one and only known implementation of GlobalKTable Contract in Kafka Streams.

results matching ""

    No results matching ""