diff --git a/theodolite-benchmarks/docker-test/uc1-beam-samza/docker-compose.yml b/theodolite-benchmarks/docker-test/uc1-beam-samza/docker-compose.yml
index ded1e0c38ab05b9c265da670dfaecbc5d6fab609..10f8918ca4469a81c6152515f258e7f3f2e36efe 100644
--- a/theodolite-benchmarks/docker-test/uc1-beam-samza/docker-compose.yml
+++ b/theodolite-benchmarks/docker-test/uc1-beam-samza/docker-compose.yml
@@ -1,4 +1,4 @@
-version: '2'
+version: '2.2'
 services:
   zookeeper:
     image: confluentinc/cp-zookeeper
@@ -33,11 +33,12 @@ services:
       SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL: 'zookeeper:2181'
   benchmark:
     image: uc1-beam-samza:latest
+    scale: 1
     depends_on:
       - schema-registry
       - kafka
     environment:
-      MAX_SOURCE_PARALLELISM: 1
+      MAX_SOURCE_PARALLELISM: 1024
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
   load-generator: 
diff --git a/theodolite-benchmarks/docker-test/uc2-beam-samza/docker-compose.yml b/theodolite-benchmarks/docker-test/uc2-beam-samza/docker-compose.yml
index 5f03929108ba738da761f36334bf3c608a5f3c90..50b9b1f7ce83216205437c5918033c192018f428 100644
--- a/theodolite-benchmarks/docker-test/uc2-beam-samza/docker-compose.yml
+++ b/theodolite-benchmarks/docker-test/uc2-beam-samza/docker-compose.yml
@@ -1,4 +1,4 @@
-version: '2'
+version: '2.2'
 services:
   zookeeper:
     image: confluentinc/cp-zookeeper
@@ -33,11 +33,12 @@ services:
       SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL: 'zookeeper:2181'
   benchmark:
     image: uc2-beam-samza:latest
+    scale: 1
     depends_on:
       - schema-registry
       - kafka
     environment:
-      MAX_SOURCE_PARALLELISM: 1
+      MAX_SOURCE_PARALLELISM: 1024
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
       KAFKA_WINDOW_DURATION_MINUTES: 60
diff --git a/theodolite-benchmarks/docker-test/uc3-beam-samza/docker-compose.yml b/theodolite-benchmarks/docker-test/uc3-beam-samza/docker-compose.yml
index 8c13e774a389e36d451b953106194e9a69aa3244..b1394e5e9a88e93f99e482fc0749d8340332c002 100644
--- a/theodolite-benchmarks/docker-test/uc3-beam-samza/docker-compose.yml
+++ b/theodolite-benchmarks/docker-test/uc3-beam-samza/docker-compose.yml
@@ -1,4 +1,4 @@
-version: '2'
+version: '2.2'
 services:
   zookeeper:
     image: confluentinc/cp-zookeeper
@@ -33,11 +33,12 @@ services:
       SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL: 'zookeeper:2181'
   benchmark:
     image: uc3-beam-samza:latest
+    scale: 1
     depends_on:
       - schema-registry
       - kafka
     environment:
-      MAX_SOURCE_PARALLELISM: 1
+      MAX_SOURCE_PARALLELISM: 1024
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
   load-generator: 
diff --git a/theodolite-benchmarks/docker-test/uc4-beam-samza/docker-compose.yml b/theodolite-benchmarks/docker-test/uc4-beam-samza/docker-compose.yml
index 7bcc71193273ab0ab8696a70bcbfda737a2bda73..ea818275cd2b16f92688b5a4181ecc138b321050 100644
--- a/theodolite-benchmarks/docker-test/uc4-beam-samza/docker-compose.yml
+++ b/theodolite-benchmarks/docker-test/uc4-beam-samza/docker-compose.yml
@@ -1,4 +1,4 @@
-version: '2'
+version: '2.2'
 services:
   zookeeper:
     image: confluentinc/cp-zookeeper
@@ -33,11 +33,12 @@ services:
       SCHEMA_REGISTRY_KAFKASTORE_CONNECTION_URL: 'zookeeper:2181'
   benchmark:
     image: uc4-beam-samza:latest
+    scale: 1
     depends_on:
       - schema-registry
       - kafka
     environment:
-      MAX_SOURCE_PARALLELISM: 1
+      MAX_SOURCE_PARALLELISM: 1024
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
   load-generator: