muralibasani commented on code in PR #22458:
URL: https://github.com/apache/kafka/pull/22458#discussion_r4383086540
##########
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##########
@@ -1456,8 +1467,19 @@ private long maxUncommittedBytesPerThread(final int
numStreamThreads) {
return divisor == 0 ? totalMax : totalMax / divisor;
}
- private void resizeThreadCache(final long cacheSizePerThread) {
- processStreamThread(thread -> thread.resizeCache(cacheSizePerThread));
+ // Pass through -1L unchanged so StreamThread can tell the bytes guard is
disabled.
+ private long bufferSizePerThread(final int numStreamThreads) {
+ if (inputBufferMaxBytes == -1L) {
Review Comment:
Removed it, along with UNDEFINED_INPUT_BUFFER_MAX_BYTES and its two checks
in StreamThread.
--
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]
