1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
#!/bin/bash
set -eu
PY_DOCKER_BIN="$( cd "$( dirname "${BASH_SOURCE[0]}" )" >/dev/null && pwd )"
source ${PY_DOCKER_BIN}/../.env
# Wait for http service listener to come up and start serving
# $1 http service name
# $2 http service address
await_http() {
local exit_code
local attempt=0
echo "Awaiting $1..."
until curl ${2} || [[ ${attempt} -gt 5 ]]; do
echo "Still awaiting $1..."
let "attempt+=1"
sleep 6
done
if [[ ${attempt} -lt 5 ]]; then
return
fi
echo "$1 readiness test failed: aborting"
exit 1
}
echo "Configuring Environment..."
source ${PY_DOCKER_SOURCE}/.env
echo "Generating SSL certs..."
${PY_DOCKER_BIN}/certify.sh
echo "Deploying cluster..."
docker-compose -f $PY_DOCKER_COMPOSE_FILE up -d
echo "Setting throttle for throttle test..."
docker-compose -f $PY_DOCKER_COMPOSE_FILE exec kafka sh -c "
/usr/bin/kafka-configs --bootstrap-server kafka:9092 \
--alter --add-config 'producer_byte_rate=1,consumer_byte_rate=1,request_percentage=001' \
--entity-name throttled_client --entity-type clients"
await_http "schema-registry" "http://localhost:8081"
await_http "schema-registry-basic-auth" "http://localhost:8083"
|
