diff options
author | solsson <solsson@gmail.com> | 2018-02-03 20:39:54 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2018-02-03 20:39:54 +0100 |
commit | ea1acda0edc59c670aa5ece60863b7f69839368c (patch) | |
tree | 76c52a14a19fccdc4fd58d37e24bd1afa5946d77 /avro-tools/test/70rest-test1.yml | |
parent | 85ef561428d2721f03cf3c33b8e277d395ef90e2 (diff) | |
parent | 4d26f51626ef5c9bd42db9ff8cc7ed0f42e90b2c (diff) | |
download | kubernetes-kafka-ea1acda0edc59c670aa5ece60863b7f69839368c.tar.gz kubernetes-kafka-ea1acda0edc59c670aa5ece60863b7f69839368c.tar.bz2 kubernetes-kafka-ea1acda0edc59c670aa5ece60863b7f69839368c.zip |
Merge pull request #102 from Yolean/1.8-confluent-rest
Schema Registry and REST Proxy as opt-in folder
Diffstat (limited to 'avro-tools/test/70rest-test1.yml')
-rw-r--r-- | avro-tools/test/70rest-test1.yml | 43 |
1 files changed, 43 insertions, 0 deletions
diff --git a/avro-tools/test/70rest-test1.yml b/avro-tools/test/70rest-test1.yml new file mode 100644 index 0000000..f26cdc9 --- /dev/null +++ b/avro-tools/test/70rest-test1.yml @@ -0,0 +1,43 @@ +apiVersion: batch/v1 +kind: Job +metadata: + name: rest-test1 + namespace: kafka +spec: + backoffLimit: 1 + template: + metadata: + name: rest-test1 + spec: + containers: + - name: curl + image: solsson/curl@sha256:523319afd39573746e8f5a7c98d4a6cd4b8cbec18b41eb30c8baa13ede120ce3 + env: + - name: REST + value: http://rest.kafka.svc.cluster.local + - name: TOPIC + value: test1 + command: + - /bin/bash + - -ce + - > + curl --retry 10 --retry-delay 30 --retry-connrefused -I $REST; + + curl -H 'Accept: application/vnd.kafka.v2+json' $REST/topics; + + 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 -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.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 "{\"topics\":[\"$TOPIC\"]}" $REST/consumers/my_json_consumer/instances/my_consumer_instance/subscription -v; + + curl -X GET -H "Accept: application/vnd.kafka.json.v2+json" $REST/consumers/my_json_consumer/instances/my_consumer_instance/records -v; + + curl -X DELETE -H "Content-Type: application/vnd.kafka.v2+json" $REST/consumers/my_json_consumer/instances/my_consumer_instance -v; + + sleep 300 + restartPolicy: Never |