aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStaffan Olsson <staffan@repos.se>2017-08-01 15:05:06 +0200
committerStaffan Olsson <staffan@repos.se>2017-08-01 15:05:06 +0200
commitff698326390c191a39c95b38d019f7b306fb0063 (patch)
tree98c68928e5d83ed2c0c2ad8384df6042e95325de
parentcaf56c71bd36be27f1626e1849889a6b893035d4 (diff)
downloadkubernetes-kafka-ff698326390c191a39c95b38d019f7b306fb0063.tar.gz
kubernetes-kafka-ff698326390c191a39c95b38d019f7b306fb0063.tar.bz2
kubernetes-kafka-ff698326390c191a39c95b38d019f7b306fb0063.zip
Demonstrates that rest+schemas work together
-rw-r--r--test/rest-curl.yml21
1 files changed, 21 insertions, 0 deletions
diff --git a/test/rest-curl.yml b/test/rest-curl.yml
index 5c6489d..998a36f 100644
--- a/test/rest-curl.yml
+++ b/test/rest-curl.yml
@@ -71,6 +71,27 @@ data:
curl -X GET $SCHEMAS/subjects/$TOPIC-value/versions/1
echo ""
+ # rest + schema
+ # TODO new topic needed because this breaks json consumer above
+
+ curl -X POST -H "Content-Type: application/vnd.kafka.avro.v2+json" \
+ -H "Accept: application/vnd.kafka.v2+json" \
+ --data '{"value_schema": "{\"type\": \"record\", \"name\": \"User\", \"fields\": [{\"name\": \"name\", \"type\": \"string\"}]}", "records": [{"value": {"name": "testUser"}}]}' \
+ $REST/topics/$TOPIC
+ echo ""
+
+ curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" \
+ --data '{"name": "my_consumer_instance", "format": "avro", "auto.offset.reset": "earliest"}' \
+ $REST/consumers/my_avro_consumer
+ echo ""
+
+ curl -X POST -H "Content-Type: application/vnd.kafka.v2+json" \
+ --data "{\"topics\":[\"$TOPIC\"]}" \
+ $REST/consumers/my_avro_consumer/instances/my_consumer_instance/subscription
+
+ curl -X GET -H "Accept: application/vnd.kafka.avro.v2+json" \
+ $REST/consumers/my_avro_consumer/instances/my_consumer_instance/records
+
tail -f /tmp/testlog
continue.sh: |-