Enhance error handling

theodolite-benchmarks/docker-test/smoketest-runner.sh

@@ -12,7 +12,7 @@ sleep 5s
 docker-compose ps
 
 if test -f "./test.sh"; then
-    ./test.sh
+    timeout 3m ./test.sh
     RETURN=$?
 else
     RETURN=$?

theodolite-benchmarks/docker-test/uc2-beam-flink/test.sh

 #!/bin/sh
 
+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=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc2-beam-samza/test.sh

 #!/bin/sh
 
+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=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc2-flink/test.sh

 #!/bin/sh
 
+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=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc2-kstreams/test.sh

 #!/bin/sh
 
+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=s -r http://schema-registry:8081 -f '%k:%s\n' -c 20 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc3-beam-flink/test.sh

 #!/bin/sh
 
+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=s -r http://schema-registry:8081 -f '%k:%s\n' -c 600 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc3-beam-samza/test.sh

 #!/bin/sh
 
+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=s -r http://schema-registry:8081 -f '%k:%s\n' -c 600 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc3-kstreams/test.sh

 #!/bin/sh
 
+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=s -r http://schema-registry:8081 -f '%k:%s\n' -c 600 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc4-beam-flink/test.sh

 #!/bin/sh
 
+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 2000 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc4-beam-samza/test.sh

 #!/bin/sh
 
+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 2000 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc4-flink/test.sh

 #!/bin/sh
 
+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 500 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |

theodolite-benchmarks/docker-test/uc4-kstreams/test.sh

 #!/bin/sh
 
+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 |
     tee /dev/stderr |
     awk -F ':' '!/^%/ {print $1}' |