-docker-compose restart producer-0 producer-1
-while ! [[ $(http -b :8000/actuator/health | jq -r .status) =~ "UP" ]]; do echo Waiting for :8000/actuator/health; sleep 1; done
-while ! [[ $(http -b :8001/actuator/health | jq -r .status) =~ "UP" ]]; do echo Waiting for :8001/actuator/health; sleep 1; done
-docker-compose exec cli kafkacat -C -b kafka:9092 -t test -o 0 -f'p=%p|o=%o|k=%k|v=%s\n' -q -c20
-
-echo "Messages from peter"
-docker-compose logs consumer | grep k=peter
-echo "Messages from beate"
-docker-compose logs consumer | grep k=beate
-echo "Messages from foo"
-docker-compose logs consumer | grep k=foo