nicktelford commented on code in PR #15264:
URL: https://github.com/apache/kafka/pull/15264#discussion_r1473083327
##########
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##########
@@ -505,6 +505,11 @@ public class StreamsConfig extends AbstractConfig {
public static final String STATESTORE_CACHE_MAX_BYTES_CONFIG =
"statestore.cache.max.bytes";
public static final String STATESTORE_CACHE_MAX_BYTES_DOC = "Maximum
number of memory bytes to be used for statestore cache across all threads";
+ public static final String STATESTORE_UNCOMMITTED_MAX_BYTES_CONFIG =
"statestore.uncommitted.max.bytes";
+ public static final String STATESTORE_UNCOMMITTED_MAX_BYTES_DOC = "Maximum
number of memory bytes to be used to buffer uncommitted state-store records. " +
+ "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.";
Review Comment:
I've removed that line entirely now.
--
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
