Skip to content
Snippets Groups Projects

Add smoketest for UC3 Flink

Merged Sören Henning requested to merge Add-smoketest-for-uc3-flink into main
2 files
+ 21
0
Compare changes
  • Side-by-side
  • Inline
Files
2
#!/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}' |
sort |
uniq |
wc -l |
grep "\b10\b"
\ No newline at end of file
Loading