1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
|
#!/bin/bash
#
set -e
source venv/bin/activate
librdkafka_version=$(python3 -c 'from confluent_kafka import libversion; print(libversion()[0])')
if [[ -z $librdkafka_version ]]; then
echo "No librdkafka version found.."
exit 1
fi
set -u
topic="pysoak-$TESTID-$librdkafka_version"
echo "Starting soak client using topic $topic"
set +x
time opentelemetry-instrument confluent-kafka-python/tests/soak/soakclient.py -i $TESTID -t $topic -r 80 -f confluent-kafka-python/ccloud.config 2>&1
ret=$?
echo "Python client exited with status $ret"
exit $ret
|
