diff --git a/theodolite-benchmarks/docker-test/uc2-beam-flink/test.sh b/theodolite-benchmarks/docker-test/uc2-beam-flink/test.sh index 5a98b31a3e1d898452d788c8c01fb874634a830b..047ea6cc95a129444fb3d4aaef7463404d07ecdc 100755 --- a/theodolite-benchmarks/docker-test/uc2-beam-flink/test.sh +++ b/theodolite-benchmarks/docker-test/uc2-beam-flink/test.sh @@ -1,6 +1,6 @@ #!/bin/sh -docker-compose exec kcat kcat -C -b kafka:9092 -t output -s key=s -s value=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 | +docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 | tee /dev/stderr | awk -F ':' '!/^%/ {print $1}' | sort | diff --git a/theodolite-benchmarks/docker-test/uc2-beam-samza/test.sh b/theodolite-benchmarks/docker-test/uc2-beam-samza/test.sh index 5a98b31a3e1d898452d788c8c01fb874634a830b..047ea6cc95a129444fb3d4aaef7463404d07ecdc 100755 --- a/theodolite-benchmarks/docker-test/uc2-beam-samza/test.sh +++ b/theodolite-benchmarks/docker-test/uc2-beam-samza/test.sh @@ -1,6 +1,6 @@ #!/bin/sh -docker-compose exec kcat kcat -C -b kafka:9092 -t output -s key=s -s value=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 | +docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 | tee /dev/stderr | awk -F ':' '!/^%/ {print $1}' | sort | diff --git a/theodolite-benchmarks/docker-test/uc2-flink/test.sh b/theodolite-benchmarks/docker-test/uc2-flink/test.sh index 5a98b31a3e1d898452d788c8c01fb874634a830b..047ea6cc95a129444fb3d4aaef7463404d07ecdc 100755 --- a/theodolite-benchmarks/docker-test/uc2-flink/test.sh +++ b/theodolite-benchmarks/docker-test/uc2-flink/test.sh @@ -1,6 +1,6 @@ #!/bin/sh -docker-compose exec kcat kcat -C -b kafka:9092 -t output -s key=s -s value=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 | +docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 | tee /dev/stderr | awk -F ':' '!/^%/ {print $1}' | sort | diff --git a/theodolite-benchmarks/docker-test/uc2-kstreams/test.sh b/theodolite-benchmarks/docker-test/uc2-kstreams/test.sh index 5a98b31a3e1d898452d788c8c01fb874634a830b..047ea6cc95a129444fb3d4aaef7463404d07ecdc 100755 --- a/theodolite-benchmarks/docker-test/uc2-kstreams/test.sh +++ b/theodolite-benchmarks/docker-test/uc2-kstreams/test.sh @@ -1,6 +1,6 @@ #!/bin/sh -docker-compose exec kcat kcat -C -b kafka:9092 -t output -s key=s -s value=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 | +docker-compose exec -T kcat kcat -C -b kafka:9092 -t output -s key=s -s value=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 | tee /dev/stderr | awk -F ':' '!/^%/ {print $1}' | sort |