aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorStaffan Olsson <staffan@repos.se>2017-07-27 05:52:14 +0200
committerStaffan Olsson <staffan@repos.se>2017-07-29 14:53:32 +0200
commitd340d41cc7eda1c44dd069257fa7eabfbc01ec03 (patch)
treebcd37a7e78fd5104e2a164a57263370347753ba2
parentdfc65f1ce19fb93d6a5af4ce52a3cc35acd35e25 (diff)
downloadkubernetes-kafka-d340d41cc7eda1c44dd069257fa7eabfbc01ec03.tar.gz
kubernetes-kafka-d340d41cc7eda1c44dd069257fa7eabfbc01ec03.tar.bz2
kubernetes-kafka-d340d41cc7eda1c44dd069257fa7eabfbc01ec03.zip
Tests rest-proxy, but hangs on GET /consumers/.../records
-rw-r--r--test/70rest-test1.yml39
1 files changed, 39 insertions, 0 deletions
diff --git a/test/70rest-test1.yml b/test/70rest-test1.yml
new file mode 100644
index 0000000..e52da30
--- /dev/null
+++ b/test/70rest-test1.yml
@@ -0,0 +1,39 @@
+apiVersion: batch/v1
+kind: Job
+metadata:
+ name: rest-test1
+ namespace: kafka
+spec:
+ template:
+ metadata:
+ name: rest-test1
+ spec:
+ containers:
+ - name: curl
+ image: solsson/curl@sha256:8b0927b81d10043e70f3e05e33e36fb9b3b0cbfcbccdb9f04fd53f67a270b874
+ env:
+ - name: REST
+ value: http://rest.kafka.svc.cluster.local
+ - name: TOPIC
+ value: test1
+ command:
+ - /bin/sh
+ - -c
+ - >
+ curl -I $REST;
+ curl -X POST $REST/consumers/list;
+
+ # http://docs.confluent.io/current/kafka-rest/docs/intro.html
+
+ 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