Skip to content
Snippets Groups Projects
Commit 118614d5 authored by Mikhail Karnevskiy's avatar Mikhail Karnevskiy
Browse files

modify kafka test to be compatible with build env

parent 19fff392
No related branches found
No related tags found
No related merge requests found
...@@ -16,13 +16,13 @@ receiver_folder_online=${receiver_root_folder}/beamline/${beamline}/current ...@@ -16,13 +16,13 @@ receiver_folder_online=${receiver_root_folder}/beamline/${beamline}/current
Cleanup() { Cleanup() {
echo cleanup echo cleanup
set +e set +e
nomad stop receiver cp /receiver_tcp.json /receiver.json
nomad run receiver_tcp.nmd supervisorctl restart receiver
while true while true
do do
sleep 1 sleep 1
curl --silent 127.0.0.1:8400/asapo-discovery/v0.1/asapo-receiver?protocol=v0.6 --stderr - | grep 127.0.0.1 || continue curl --silent 127.0.0.1:8400/asapo-discovery/v0.1/asapo-receiver?protocol=v0.6 --stderr - | grep localhost || continue
echo recevier started echo recevier tcp started
break break
done done
rm -rf ${receiver_root_folder} rm -rf ${receiver_root_folder}
...@@ -47,14 +47,14 @@ done ...@@ -47,14 +47,14 @@ done
BOOTSTRAP=$(cat bootstrap) BOOTSTRAP=$(cat bootstrap)
echo "Read kafka bootstrap: ${BOOTSTRAP}" echo "Read kafka bootstrap: ${BOOTSTRAP}"
sed "s/BROKER_LIST/${BOOTSTRAP}/g" /receiver_kafka.json > /receiver.json
nomad stop receiver cat /receiver.json
nomad run -var receiver_kafka_metadata_broker_list="${BOOTSTRAP}" receiver_kafka.nmd supervisorctl restart receiver
while true while true
do do
sleep 1 sleep 1
curl --silent 127.0.0.1:8400/asapo-discovery/v0.1/asapo-receiver?protocol=v0.6 --stderr - | grep 127.0.0.1 || continue curl --silent 127.0.0.1:8400/asapo-discovery/v0.1/asapo-receiver?protocol=v0.6 --stderr - | grep localhost || continue
echo recevier started echo recevier kafka started
break break
done done
...@@ -63,6 +63,7 @@ mkdir -p ${receiver_folder_online} ...@@ -63,6 +63,7 @@ mkdir -p ${receiver_folder_online}
$1 localhost:8400 ${beamtime_id} 100 1 1 100 30 $1 localhost:8400 ${beamtime_id} 100 1 1 100 30
ls -ln ${receiver_folder_online}/raw/1
ls -ln ${receiver_folder_online}/raw/1 | awk '{ print $5 }'| grep 100000 ls -ln ${receiver_folder_online}/raw/1 | awk '{ print $5 }'| grep 100000
wait $KAFKA_PID wait $KAFKA_PID
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment