nicktelford opened a new pull request, #15264: URL: https://github.com/apache/kafka/pull/15264
This configuration controls the maximum amount of local state store data to buffer in transaction buffers. When the total uncommitted data, across all stores and all threads, exceeds this value, a Task commit will be triggered, even if `commit.interval.ms` has not yet elapsed. This prevents application from hitting OutOfMemory errors when the `commit.interval.ms` is set to a high value, and transactional state stores are in-use. StateStores that support transactions can implement `approximateNumUncommittedBytes` to track the size of the data not yet committed to the store. By default, `approximateUncommitted` returns `0`, which means that all data is immediately committed to the state store. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
