Skip to content

Commit 06eef9a

Browse files
authored
perf(log): increase FETCH_BATCH_SIZE to 512KB in StreamSegmentInputStream (#2722)
1 parent 201c6eb commit 06eef9a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

core/src/main/scala/kafka/log/streamaspect/ElasticLogFileRecords.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -408,7 +408,7 @@ public long lastOffset() {
408408

409409
static class StreamSegmentInputStream implements LogInputStream<RecordBatch> {
410410
@VisibleForTesting
411-
protected static final int FETCH_BATCH_SIZE = 64 * 1024;
411+
protected static final int FETCH_BATCH_SIZE = 512 * 1024;
412412
private final ElasticLogFileRecords elasticLogFileRecords;
413413
private final Queue<RecordBatch> remaining = new LinkedList<>();
414414
private final int maxSize;

0 commit comments

Comments
 (0)