Skip to content

Latest commit

 

History

History
36 lines (25 loc) · 1.58 KB

kafka-streams-AbstractStateStoreFactory.adoc

File metadata and controls

36 lines (25 loc) · 1.58 KB

AbstractStateStoreFactory

AbstractStateStoreFactory is an abstract StateStoreFactory that…​FIXME

AbstractStateStoreFactory gives the users registry. A new processor name is added when InternalTopologyBuilder is requested to connect a state store with a processor node.

Note
AbstractStateStoreFactory is a Java abstract class and cannot be created directly. It is created indirectly when the concrete AbstractStateStoreFactories are.
Table 1. StateStoreFactories
StateStoreFactory Description

StoreBuilderFactory

StateStoreSupplierFactory

Creating AbstractStateStoreFactory Instance

AbstractStateStoreFactory takes the following when created:

  • Name

  • loggingEnabled flag

  • windowStore flag

  • logConfig as Map<String, String>

AbstractStateStoreFactory initializes the internal registries and counters.

Note
AbstractStateStoreFactory is a Java abstract class and cannot be created directly. It is created indirectly when the concrete AbstractStateStoreFactories are.