diff --git a/services/apps/data_sink_worker/src/main.ts b/services/apps/data_sink_worker/src/main.ts
index d721fb9dd7..3367ace10c 100644
--- a/services/apps/data_sink_worker/src/main.ts
+++ b/services/apps/data_sink_worker/src/main.ts
@@ -7,7 +7,7 @@ import { initializeSentimentAnalysis } from '@crowd/sentiment'
 
 const log = getServiceLogger()
 
-const MAX_CONCURRENT_PROCESSING = 2
+const MAX_CONCURRENT_PROCESSING = 4
 
 setImmediate(async () => {
   log.info('Starting data sink worker...')