From 713743ec4469dd40b63344fe7b3d81f6dce5a643 Mon Sep 17 00:00:00 2001 From: Staffan Olsson Date: Sat, 29 Jul 2017 16:51:42 +0200 Subject: We should probably wait for CP 3.3.0 because ... I'm not getting the expected behavior. Might also be because of low resources on minikube, but 3.3.0 should only be a few days away. --- test/rest-curl.yml | 23 ++++++++++++++++------- 1 file changed, 16 insertions(+), 7 deletions(-) diff --git a/test/rest-curl.yml b/test/rest-curl.yml index db5758a..05fc178 100644 --- a/test/rest-curl.yml +++ b/test/rest-curl.yml @@ -9,17 +9,26 @@ data: setup.sh: |- touch /tmp/testlog - # Don't complete startup until rest proxy is up and running - curl --retry 10 --retry-delay 30 --retry-connrefused -I $REST; + # Keep starting up until rest proxy is up and running + curl --retry 10 --retry-delay 30 --retry-connrefused -I -s $REST - curl -H 'Accept: application/vnd.kafka.v2+json' $REST/topics; + curl -H 'Accept: application/vnd.kafka.v2+json' $REST/topics + echo "" - curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/test1; - curl -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" -H "Accept: application/vnd.kafka.v2+json" --data "{\"records\":[{\"value\":\"Test from $HOSTNAME at $(date)\"}]}" $REST/topics/$TOPIC -v; - curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/test2; + curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/$TOPIC + echo "" - curl -X POST -H "Content-Type: application/vnd.kafka.json.v2+json" -H "Accept: application/vnd.kafka.v2+json" --data '{"records":[{"value":{"foo":"bar"}}]}' $REST/topics/$TOPIC -v; + curl -X POST \ + -H "Content-Type: application/vnd.kafka.json.v2+json" -H "Accept: application/vnd.kafka.v2+json" \ + --data "{\"records\":[{\"value\":\"Test from $HOSTNAME at $(date -u -Iseconds)\"}]}" \ + $REST/topics/$TOPIC -v --max-time 30 \ + || echo " (timeout might be ok because we only want to send one message)" + # TODO why does the above block? + + + curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/$TOPIC/partitions + echo "" curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data '{"name": "my_consumer_instance", "format": "json", "auto.offset.reset": "earliest"}' $REST/consumers/my_json_consumer -v; -- cgit v1.2.3