T
- State store typepublic interface StateStoreSupplier<T extends StateStore>
StateStore
instances.Modifier and Type | Method and Description |
---|---|
T |
get()
Return a new
StateStore instance. |
Map<String,String> |
logConfig()
Returns a Map containing any log configs that will be used when creating the changelog for the
StateStore |
boolean |
loggingEnabled() |
String |
name()
Return the name of this state store supplier.
|
String name()
T get()
StateStore
instance.StateStore
instance of type TMap<String,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