diff --git a/cmd/apollo-worker-notifications/main.go b/cmd/apollo-worker-notifications/main.go
index da81417..aab4550 100644
--- a/cmd/apollo-worker-notifications/main.go
+++ b/cmd/apollo-worker-notifications/main.go
@@ -126,7 +126,7 @@ func main() {
 	}
 
 	numConsumers := runtime.NumCPU() * 12
-	prefetchLimit := int64(numConsumers * 2)
+	prefetchLimit := int64(numConsumers * 32)
 
 	runtime.GOMAXPROCS(numConsumers)