From 0d4131dc9516369feb2628a42d67753eca672789 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?S=C3=B6ren=20Henning?= <soeren.henning@email.uni-kiel.de> Date: Thu, 8 Dec 2022 18:53:46 +0100 Subject: [PATCH] Align Kafka Streams smoketest with others --- .../docker-test/uc4-kstreams/docker-compose.yml | 2 ++ theodolite-benchmarks/docker-test/uc4-kstreams/test.sh | 4 ++-- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/theodolite-benchmarks/docker-test/uc4-kstreams/docker-compose.yml b/theodolite-benchmarks/docker-test/uc4-kstreams/docker-compose.yml index 6aaa02990..000214d8f 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 9b9dee7dc..a659365f9 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" -- GitLab