diff --git a/theodolite-benchmarks/docker-test/uc4-kstreams/docker-compose.yml b/theodolite-benchmarks/docker-test/uc4-kstreams/docker-compose.yml
index 6aaa02990841547edb6059e4e2fbf3b28b50985c..000214d8fda2823c6fccc9257baaa2f500cc76c5 100755
--- a/theodolite-benchmarks/docker-test/uc4-kstreams/docker-compose.yml
+++ b/theodolite-benchmarks/docker-test/uc4-kstreams/docker-compose.yml
@@ -45,6 +45,8 @@ services:
     environment:
       KAFKA_BOOTSTRAP_SERVERS: kafka:9092
       SCHEMA_REGISTRY_URL: http://schema-registry:8081
+      COMMIT_INTERVAL_MS: 1000
+      GRACE_PERIOD_MS: 5000
   load-generator: 
     image: ghcr.io/cau-se/theodolite-uc4-workload-generator:${THEODOLITE_TAG:-latest}
     depends_on:
diff --git a/theodolite-benchmarks/docker-test/uc4-kstreams/test.sh b/theodolite-benchmarks/docker-test/uc4-kstreams/test.sh
index 9b9dee7dc78e7a587b9f2e5b778066e5bc099755..a659365f94e5bdd42cad8bc646b5dab563f59563 100755
--- a/theodolite-benchmarks/docker-test/uc4-kstreams/test.sh
+++ b/theodolite-benchmarks/docker-test/uc4-kstreams/test.sh
@@ -2,10 +2,10 @@
 
 until docker-compose exec -T kcat kcat -L -b kafka:9092 -t output -J | jq -r '.topics[0].partitions | length' | grep "\b3\b"; do sleep 5s; done
 
-docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=avro -r http://schema-registry:8081 -f '%k:%s\n' -c 32 |
+docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=avro -r http://schema-registry:8081 -f '%k:%s\n' -c 300 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |
     sort |
     uniq |
     wc -l |
-    grep "\b16\b"
+    grep "\b21\b"