blob: f26cdc96802fa130087bf5d23ead5c55f6f80051 (
plain) (
tree)
|
|
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
|