diff --git a/internal/cmd/worker.go b/internal/cmd/worker.go
index 1a76cd1..3d96d2a 100644
--- a/internal/cmd/worker.go
+++ b/internal/cmd/worker.go
@@ -52,7 +52,7 @@ func WorkerCmd(ctx context.Context) *cobra.Command {
 
 			tracer := otel.Tracer(tag)
 
-			poolSize := consumers / 4
+			poolSize := consumers / 16
 
 			db, err := cmdutil.NewDatabasePool(ctx, poolSize)
 			if err != nil {