THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Public Interfaces
New configuration:
Name | Default | Description |
---|---|---|
statestore.uncommitted.max.records |
...
-1 | 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 |
...
. |
...
statestore.uncommitted.max.bytes |
...
67108864 (64 MB) | 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 |
...
. Note: if this is too high or unbounded, it's possible for RocksDB to trigger out-of-memory errors. |
Changed:
- org.apache.kafka.streams.processor.StateStore
...