Skip to content

Commit 1f5046e

Browse files
committed
Changes to run with EC2
1 parent 9c7476e commit 1f5046e

File tree

2 files changed

+18
-1
lines changed

2 files changed

+18
-1
lines changed

tests/soak/ccloud.config.example

+9
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
bootstrap.servers=<add your bootstraps here>
2+
sasl.mechanisms=PLAIN
3+
security.protocol=SASL_SSL
4+
sasl.username=<your ccloud access key>
5+
sasl.password=<your ccloud secret>
6+
enable.idempotence=true
7+
debug=eos,generic,broker,security,consumer
8+
linger.ms=2
9+
compression.type=lz4

tests/soak/run.sh

+9-1
Original file line numberDiff line numberDiff line change
@@ -11,12 +11,20 @@ if [[ -z $librdkafka_version ]]; then
1111
exit 1
1212
fi
1313

14+
if [[ -z $STY ]]; then
15+
echo "This script should be run from inside a screen session"
16+
exit 1
17+
fi
18+
1419
set -u
1520
topic="pysoak-$TESTID-$librdkafka_version"
21+
logfile="${topic}.log.bz2"
22+
1623

1724
echo "Starting soak client using topic $topic"
1825
set +x
19-
time opentelemetry-instrument confluent-kafka-python/tests/soak/soakclient.py -i $TESTID -t $topic -r 80 -f confluent-kafka-python/ccloud.config 2>&1
26+
time confluent-kafka-python/tests/soak/soakclient.py -t $topic -r 80 -f confluent-kafka-python/ccloud.config 2>&1 \
27+
| tee /dev/stderr | bzip2 > $logfile
2028
ret=$?
2129
echo "Python client exited with status $ret"
2230
exit $ret

0 commit comments

Comments
 (0)