blob: ce7b0190c176b3fd154bac118a2317d4e580660e (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
|
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 --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
|
