diff options
| author | solsson <solsson@gmail.com> | 2017-08-01 14:39:30 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2017-08-01 14:39:30 +0200 |
| commit | 7b4cfb48d0fe25a3c76d6d183a826ec8868d70b7 (patch) | |
| tree | 05d684f8f601fee5f61ed0bace1c1433b9999cd3 /test/rest-curl.yml | |
| parent | 713743ec4469dd40b63344fe7b3d81f6dce5a643 (diff) | |
| parent | ac5c75a977c796313dc5f84831aa50529457be38 (diff) | |
| download | kubernetes-kafka-7b4cfb48d0fe25a3c76d6d183a826ec8868d70b7.tar.gz kubernetes-kafka-7b4cfb48d0fe25a3c76d6d183a826ec8868d70b7.tar.bz2 kubernetes-kafka-7b4cfb48d0fe25a3c76d6d183a826ec8868d70b7.zip | |
Merge pull request #54 from Yolean/addon-rest-new-build
Use config files and kafka-jre based build for Confluent Platform services
Diffstat (limited to 'test/rest-curl.yml')
| -rw-r--r-- | test/rest-curl.yml | 34 |
1 files changed, 23 insertions, 11 deletions
diff --git a/test/rest-curl.yml b/test/rest-curl.yml index 05fc178..f8dc8de 100644 --- a/test/rest-curl.yml +++ b/test/rest-curl.yml @@ -12,31 +12,43 @@ data: # Keep starting up until rest proxy is up and running curl --retry 10 --retry-delay 30 --retry-connrefused -I -s $REST + curl -s -H 'Accept: application/vnd.kafka.v2+json' $REST/brokers | egrep '."brokers":.0' - curl -H 'Accept: application/vnd.kafka.v2+json' $REST/topics + curl -s -H 'Accept: application/vnd.kafka.v2+json' $REST/topics echo "" - curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/$TOPIC + curl -s -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\":\"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? - + $REST/topics/$TOPIC + echo "" - curl --retry 10 -H 'Accept: application/vnd.kafka.v2+json' $REST/topics/$TOPIC/partitions + curl -s -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; + 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 + echo "" - curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" --data "{\"topics\":[\"$TOPIC\"]}" $REST/consumers/my_json_consumer/instances/my_consumer_instance/subscription -v; + curl -X POST \ + -H "Content-Type: application/vnd.kafka.v2+json" \ + --data "{\"topics\":[\"$TOPIC\"]}" \ + $REST/consumers/my_json_consumer/instances/my_consumer_instance/subscription \ + -w "%{http_code}" + echo "" - curl -X GET -H "Accept: application/vnd.kafka.json.v2+json" $REST/consumers/my_json_consumer/instances/my_consumer_instance/records -v; + curl -X GET \ + -H "Accept: application/vnd.kafka.json.v2+json" \ + $REST/consumers/my_json_consumer/instances/my_consumer_instance/records - curl -X DELETE -H "Content-Type: application/vnd.kafka.v2+json" $REST/consumers/my_json_consumer/instances/my_consumer_instance -v; + curl -X DELETE \ + -H "Content-Type: application/vnd.kafka.v2+json" \ + $REST/consumers/my_json_consumer/instances/my_consumer_instance tail -f /tmp/testlog |