T
- the type of store to buildpublic interface StoreBuilder<T extends StateStore>
StateStore
wrapped with optional caching and logging.Modifier and Type | Method and Description |
---|---|
T |
build()
Build the store as defined by the builder.
|
java.util.Map<java.lang.String,java.lang.String> |
logConfig()
Returns a Map containing any log configs that will be used when creating the changelog for the
StateStore . |
boolean |
loggingEnabled() |
java.lang.String |
name()
Return the name of this state store builder.
|
StoreBuilder<T> |
withCachingEnabled()
Enable caching on the store.
|
StoreBuilder<T> |
withLoggingDisabled()
Disable the changelog for store built by this
StoreBuilder . |
StoreBuilder<T> |
withLoggingEnabled(java.util.Map<java.lang.String,java.lang.String> config)
Maintain a changelog for any changes made to the store.
|
StoreBuilder<T> withCachingEnabled()
StoreBuilder<T> withLoggingEnabled(java.util.Map<java.lang.String,java.lang.String> config)
config
- config applied to the changelog topicStoreBuilder<T> withLoggingDisabled()
StoreBuilder
.
This will turn off fault-tolerance for your store.
By default the changelog is enabled.T build()
StateStore
java.util.Map<java.lang.String,java.lang.String> logConfig()
StateStore
.
Note: any unrecognized configs will be ignored by the Kafka brokers.
StateStore
If loggingEnabled
returns false, this function will always return an empty mapboolean loggingEnabled()
true
if the StateStore
should have logging enabledjava.lang.String name()