diff --git a/internal/worker/notifications.go b/internal/worker/notifications.go
index 546dbc0..53c0742 100644
--- a/internal/worker/notifications.go
+++ b/internal/worker/notifications.go
@@ -79,7 +79,7 @@ func (nw *notificationsWorker) Start(consumers int) error {
 		"numConsumers": consumers,
 	}).Info("starting up notifications worker")
 
-	prefetchLimit := int64(consumers * 32)
+	prefetchLimit := int64(consumers * 2)
 
 	if err := queue.StartConsuming(prefetchLimit, pollDuration); err != nil {
 		return err