T
- State store typepublic interface StateStoreSupplier<T extends StateStore>
StateStore
instances.Modifier and Type | Method and Description |
---|---|
T |
get()
Return a new
StateStore instance. |
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 supplier.
|
java.lang.String name()
T get()
StateStore
instance.StateStore
instance of type Tjava.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()
StateStore
should have logging enabled