...

Public Interfaces

New configuration:

• maxstatestore.uncommitted.state.entries.per.task: the maximum number of total StateStore entries permitted before prematurely forcing a Task commit. -1  for no maximum. Default -1.max.uncommitted.state.bytes.per.task: the maximum amount of memory to buffer uncommitted records in StateStores before prematurely forcing a Task commit. -1 for no maximum. Default: -1max.records: Maximum number of uncommitted state-store records to buffer per-task. If this limit is exceeded, a task commit will be requested. No limit: -1; Always commit: 0. Default: -1.
• statestore.uncommitted.max.bytes: Maximum number of memory bytes to be used to buffer uncommitted state-store records per-task. If this limit is exceeded, a task commit will be requested. No limit: -1; Always commit: 0.

Changed:

• org.apache.kafka.streams.processor.StateStore

...