nicktelford commented on code in PR #22597:
URL: https://github.com/apache/kafka/pull/22597#discussion_r3441110139
##########
streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java:
##########
@@ -808,6 +808,15 @@ public class StreamsConfig extends AbstractConfig {
@Deprecated
public static final String STATESTORE_CACHE_MAX_BYTES_DOC = "Maximum
number of memory bytes to be used for statestore cache across all threads";
+ /** {@code statestore.uncommitted.max.bytes} */
+ public static final String STATESTORE_UNCOMMITTED_MAX_BYTES_CONFIG =
"statestore.uncommitted.max.bytes";
+ private static final String STATESTORE_UNCOMMITTED_MAX_BYTES_DOC =
+ "The maximum number of uncommitted bytes across all transactional
state stores on this " +
+ "application instance before an early commit is triggered, regardless
of commit.interval.ms. " +
+ "The limit is divided equally across the configured number of stream
threads. " +
Review Comment:
Done. I initially refrained from mentioning this because it would deviate
from the description in the KIP.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
