diff --git a/weed/filer/filer_notify.go b/weed/filer/filer_notify.go
index 730a46226..e75bc632b 100644
--- a/weed/filer/filer_notify.go
+++ b/weed/filer/filer_notify.go
@@ -375,7 +375,7 @@ func (f *Filer) ReadPersistedLogBuffer(ctx context.Context, startPosition log_bu
 
 	// Readahead: run the visitor in a background goroutine so volume server I/O
 	// for the next log file overlaps with event processing and gRPC delivery.
-	const readaheadSize = 1024
+	const readaheadSize = 8192
 	type entryOrErr struct {
 		entry *filer_pb.LogEntry
 		err   error
diff --git a/weed/pb/filer_pb_direct_read.go b/weed/pb/filer_pb_direct_read.go
index ab9b58f30..f536b93a1 100644
--- a/weed/pb/filer_pb_direct_read.go
+++ b/weed/pb/filer_pb_direct_read.go
@@ -19,7 +19,7 @@ import (
 type LogFileReaderFn func(chunks []*filer_pb.FileChunk) (io.ReadCloser, error)
 
 // logEntryChannelSize bounds decoded entries in flight per filer stream.
-const logEntryChannelSize = 512
+const logEntryChannelSize = 4096
 
 // maxLogEntrySize guards the per-entry allocation against a corrupt size
 // prefix, mirroring the filer package's unexported constant.