diff options
| author | Staffan Olsson <staffan@repos.se> | 2017-07-29 16:51:42 +0200 |
|---|---|---|
| committer | Staffan Olsson <staffan@repos.se> | 2017-07-29 16:51:44 +0200 |
| commit | 713743ec4469dd40b63344fe7b3d81f6dce5a643 (patch) | |
| tree | 66e5739043f3b3c401b82d66501e94a7b2bf26f3 | |
| parent | 4fc6880c4ef53690a16a63ac1157d0f073ddbb4c (diff) | |
| download | kubernetes-kafka-713743ec4469dd40b63344fe7b3d81f6dce5a643.tar.gz kubernetes-kafka-713743ec4469dd40b63344fe7b3d81f6dce5a643.tar.bz2 kubernetes-kafka-713743ec4469dd40b63344fe7b3d81f6dce5a643.zip | |
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.
| -rw-r--r-- | test/rest-curl.yml | 23 |
1 files 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; |